kafka-topics.sh ---删除 --主题测试主题不适用于 kafka V 0.10.1

Question

我尝试删除一个现有的主题(我使用kafka管理控制台检查)使用以下命令;

#./kafka-topics.sh——zookeeper zookeper.xx.com:2181/chroot——delete——topic testTopic

但显示zookeeper中没有主题。[1]

我在运行时创建这些主题。(我使用高级客户端api。我认为它是在kafka集群中创建的?)

如何使用bash脚本删除主题?

[1]

Error while executing topic command : Topic targettopic does not exist on ZK path zookeeper.xx.com:2181/chroot
[2016-10-14 11:58:59,919] ERROR java.lang.IllegalArgumentException: Topic streamtargettopic does not exist on ZK path zookeeper.xx.com:2181/chroot
at kafka.admin.TopicCommand$.deleteTopic(TopicCommand.scala:169)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:69)
at kafka.admin.TopicCommand.main(TopicCommand.scala)

Answer 1

您可以使用以下命令查看Zookeeper中可用的list of topics

bin/kafka-topics.sh --list --zookeeper localhost:2181

同时在server.properties

中设置以下属性

delete.topic.enable=true 

然后尝试使用

删除主题

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test

Answer 2

如果下面的命令不能为您工作

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test

你可以通过连接zookeeper手动删除路径。

./zookeeper-shell.sh

手动删除主题

rmr /brokers/topics/<topic>