要删除的topic 名字为 test。
1.1 通过集群管理工具如ambari设置delete.topic.enable=true
delete.topic.enable
1.2 通过kafka命令 删除topic
${KAFKA_HOME}/bin/kafka-topics.sh --delete --zookeeper hostname:2181 --topic test
执行完后,topic会被标记为删除状态,随后被删除。但是如果topic正在被使用,则topic不会被删除,这种情况下需要使用zookeeper来删除,见步骤二。
2.1
通过集群管理工具如ambari 暂时关闭kafka。
2.2
通过zookeeper 来删除topic信息。
使用zkCli.sh 连接zookeeper
${zookeeper_home}/bin/zkCli.sh
删除topic
# 查看topic信息
get /brokers/topics/test
# 删除topic信息
rmr /brokers/topics/test
rmr /admin/delete_topics/test
rm -rf ./test*
2.3 重启 kafka