Skip to content

Instantly share code, notes, and snippets.

@jeffersfp

jeffersfp/kafka-del-topics.sh

Forked from hartfordfive/kafka-del-topics.sh
Created January 31, 2022 14:50
Show Gist options
  • Save jeffersfp/0d6382043059b17b447a6846f6fb5452 to your computer and use it in GitHub Desktop.
Save jeffersfp/0d6382043059b17b447a6846f6fb5452 to your computer and use it in GitHub Desktop.
Download ZIP
Script to delete all kafka topics on a given cluster
Raw
kafka-del-topics.sh
#!/bin/bash
TOPICS=$(kafka-topics --zookeeper [ZK_IP]:2181/kafka --list )
for T in $TOPICS
do
if [ "$T" != "__consumer_offsets" ]; then
kafka-topics --zookeeper [ZK_IP]:2181/kafka --delete --topic $T
fi
done
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment