1.問題描述
使用kafka命令洗掉某個topic之后,查看集群的topic串列時,被洗掉的tpoic依然存在
# /data/kafka/bin/kafka-topics.sh --delete --zookeeper zook_ip --topic system
Topic system is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.

洗掉命令是執行成功的,但是topic依然存在
# /data/kafka/bin/kafka-topics.sh --list --zookeeper zk_ip | grep system
system

2.解決方法
既然在kafka中無法洗掉topic,我們直接去zookeeper中洗掉topic
1)進入zookeeper控制臺
# ./zkCli.sh
[zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
[__consumer_offsets, system]
2)洗掉topic
rmr命令已經被棄用了,可以使用deletall命令洗掉topic
[zk: localhost:2181(CONNECTED) 3] deleteall /brokers/topics/system
3)topic已經被洗掉
# /data/kafka/bin/kafka-topics.sh --list --zookeeper zk_ip | grep system
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/384181.html
標籤:其他
上一篇:Flink基于Java的WordCount,根據滑動視窗動態排序實作
下一篇:選擇適合你的自動化測驗工具
