kafka删除topic

Posted 2023-03-26

参考技术A 另外如果topic被标记为 --marked for deletion ,这时如果去zookeeper的 /brokers/topics/ 节点下删除这个topic(不建议这样做)，虽然真的在kafka中查不到这个topic了，但是可能会引出很多意想不到的异常，例如常见的：

上面这个错误就是异常topic引起的，当producer或consumer向这个topic发送数据/读取数据时不会报错，也什么都不提示，只有打印log4j日志才可以看到上面的错误信息，此时最简单的方法就是重建topic。

怎么彻底删除kafka的topic，然后重建

参考技术A server.properties 中添加delete.topic.enable=true
执行D:\Developer\kafka_2.10-0.10.0.0\bin\windows>kafka-topics.bat --zookeeper 127.0.0.1:2181 --delete --topic TEST-TOPIC
执行zookeeper-server-stop.bat，后在重启kafka
重新发送消息即可，会自动根据配置的partitions重建
注意：不执行1步骤，就是假删除。