Kafka手动删除主题

Kafka手动删除主题 Kafka手动删除主题

主题的元数据存储在Zookeeper中的/brokes/topics/ 和/config/topics路径下，主题中的消息数据存储在log.dir 或log.dirs配置的路径下，我们只需要手动删除这些地方的内容即可。总共分为三个步骤：
1.删除Zookeeper中的节点 /config/topics/topicName:
[zk:localhost:2181/kafka (CONNECTED) 1] delete /config/topics/topicName
2.删除Zookeeper中的节点 /brokers/topics/topicName:
[zk:localhost:2181/kafka (CONNECTED) 2] rmr /brokers/topics/topicName
3.删除集群中所有与主题topicName相关的文件。注意：删除的文件是在kafka的server.properties配置中配置的log.dirs路径下。
[root@node1 kafka] rm -rf /tmp/kafka-logs/topicName*
[root@node2 kafka] rm -rf /tmp/kafka-logs/topicName*
[root@node3 kafka] rm -rf /tmp/kafka-logs/topicName*