kafka玩坏了,如何解决,删除,bug

  • Post author:
  • Post category:其他

1.kafka彻底删除topic
第一种方式:

1.修改server.properties文件

delete.topic.enable=true

auto.create.topics.enable=false

2.确保所有的生产者,消费者都已经停掉

3.执行bin/kafka-topics.sh –delete –zookeeper localhost:2181 –topic demo

4.执行bin/kafka-topics.sh –list –zookeeper localhost:2181

第二种方式:手工删除

1.在server.properties文件中配置的logs.dir路径中执行rm -rf demo*,将文件全部删除

2.在zookeeper中客户端中,使用./zkCli.sh

[zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
[__consumer_offsets, demo, test]
[zk: localhost:2181(CONNECTED) 1] rmr /brokers/topics/demo
The command ‘rmr’ has been deprecated. Please use ‘deleteall’ instead.
[zk: localhost:2181(CONNECTED) 2] deleteall /brokers/topics/demo
Node does not exist: /brokers/topics/demo
[zk: localhost:2181(CONNECTED) 3] ls /admin/delete_topics/demo
Node does not exist: /admin/delete_topics/demo

注意第二种方式可以不用重启kafka与zookeeper

彻底删除topic:

1、删除kafka存储目录(server.properties文件log.dirs配置,默认为”/tmp/kafka-logs”)相关topic目录

2、如果配置了delete.topic.enable=true直接通过命令删除,如果命令删除不掉,直接通过zookeeper-client 删除掉broker下的topic即可。


版权声明:本文为YellowXiuHui原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。