基于kafka-2.11-0.9.0.0 。

a.kill掉kafka进程,然后在server.properties里面加上delete.topic.enable=true。重启kafka。集群中的每台机器都这样操作,one by one。

b.在一个kafka broker上执行:/opt/kafka-2.11-0.9.0.0/bin/kafka-topics.sh --zookeeper hostname:2181  --delete --topic test_topic

c.kill掉kafka进程,然后转到kafka data对应的目录下删除掉对应topic的内容。

d.去掉delete.topic.enable=true,重启kafka。集群中的每台机器都这样操作,one by one。

 

如果不做c,已经删掉的topic的data会在delete.retention.ms设置的时间后才删除,默认是24小时。

 

 

相关文章:

  • 2021-12-14
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-12-03
  • 2021-07-06
猜你喜欢
  • 2021-06-29
  • 2021-05-28
  • 2021-07-03
  • 2022-12-23
  • 2021-07-31
相关资源
相似解决方案