Skip to content

Instantly share code, notes, and snippets.

@alces

alces/kafka_topics_delete.sh

Created October 30, 2019 05:56
Show Gist options
  • Save alces/8c936c9c3cb3f8ca14f0c187107962bc to your computer and use it in GitHub Desktop.
Save alces/8c936c9c3cb3f8ca14f0c187107962bc to your computer and use it in GitHub Desktop.
Download ZIP
Delete Kafka topics with matching names
Raw
kafka_topics_delete.sh
TOPIC_NAME_REGEX='(CI|TST|IT)[0-9]'
ZOOKEEPER_ADDR=127.0.0.1:2181
for topic in $(kafka-topics --zookeeper $ZOOKEEPER_ADDR --list | egrep $TOPIC_NAME_REGEX)
do
kafka-topics --zookeeper $ZOOKEEPER_ADDR --delete --topic $topic
done
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment