Skip to content

Instantly share code, notes, and snippets.

@dainiusjocas

dainiusjocas/kafka_delete_topics.sh

Created May 4, 2020 09:10
Show Gist options
  • Save dainiusjocas/3a9f10d2a8b2e7951fd92b5bb1e5fdbd to your computer and use it in GitHub Desktop.
Save dainiusjocas/3a9f10d2a8b2e7951fd92b5bb1e5fdbd to your computer and use it in GitHub Desktop.
Download ZIP
Delete kafka topics by pattern
Raw
kafka_delete_topics.sh
./bin/kafka-topics.sh --zookeeper localhost:2181 --list | grep my_pattern | while read topic; do ./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic $topic; done
@dainiusjocas
Copy link
Author

curl http://localhost:9200/_cat/indices/\*indices\?h\=index | while read index ; do curl -X DELETE http://localhost:9200/$index ; done

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment