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*

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐