ls /brokers/topics# 方法一:
- 删除topic需要kafka broker的支持,在kafka broker中使用配置项delete.topic.enable=true开启删除topic功能
方法二:
- kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete -topic topic_item_mysql
-
- 登录zookeeper或者使用 kafka 自带的zookeeper-shell.sh脚本删除topic
- 2.1 登录zookeeper,使用zkCli.sh脚本登陆zookeeper集群
- zkCli.sh -server zookeeper_host:2181
- ls /brokers/topics # 查看有哪些topic
- rmr /brokers/topics/<topic_name>
- 使用自带的脚本删除
sh zookeeper-shell.sh 172.26.129.195:2181 rmr /brokers/topics/<topic_name>
网友评论