diff --git a/devstack/files/kafka/server.properties b/devstack/files/kafka/server.properties index 1548255a4..4fb200ad1 100644 --- a/devstack/files/kafka/server.properties +++ b/devstack/files/kafka/server.properties @@ -117,3 +117,6 @@ zookeeper.connect=127.0.0.1:2181 # Timeout in ms for connecting to zookeeper zookeeper.connection.timeout.ms=1000000 +#kafka delete will have no impact if this is not set true +delete.topic.enable=true + diff --git a/devstack/plugin.sh b/devstack/plugin.sh index 69b580e5a..b78ecd086 100755 --- a/devstack/plugin.sh +++ b/devstack/plugin.sh @@ -188,6 +188,22 @@ function start_monasca_services { fi } +function delete_kafka_topics { + + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 64 --topic metrics || true + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 12 --topic events || true + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 12 --topic alarm-state-transitions || true + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 12 --topic alarm-notifications || true + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 3 --topic retry-notifications || true + /opt/kafka/bin/kafka-topics.sh --delete --zookeeper localhost:2181 \ + --replication-factor 1 --partitions 3 --topic 60-seconds-notifications || true +} + function unstack_monasca { stop_service grafana-server || true @@ -200,6 +216,7 @@ function unstack_monasca { stop_monasca-persister stop_monasca_api + delete_kafka_topics stop_service kafka || true stop_service influxdb || true