这里的Kafka的版本是0.9.0.1,查看所有Topics和分区:
1 | ./kafka-topics.sh --describe --zookeeper 192.168.244.11:2181 |
只查看所有Topic:
1 | ./kafka-topics.sh --list --zookeeper 192.168.24.244:2181 |
删除主题:
1 | ./kafka-topics.sh --zookeeper 192.168.24.244:2181 --delete --topic 0085000 |
删除主题并不是真正的删除,仅仅是标记为删除(marked for deletion),如果想彻底删除主题,可以修改kafka的配置:
1 | delete.topic.enable=true |
删除Kafka存储目录(server.properties文件log.dirs配置,默认为”/tmp/kafka-logs”)相关topic目录。配置了delete.topic.enable=true
直接通过命令删除,如果命令删除不掉,直接通过zookeeper-client删除掉broker下的topic即可。登录ZooKeeper客户端:
1 | #切换到ZooKeeper目录 |
如果不知道ZooKeeper客户端的目录,可以通过如下命令找到。
1 | find / -name zookeeper-client |