我尝试使用以下命令删除现有主题(我使用 kafka 管理控制台检查过);
#./kafka-topics.sh --zookeeper zookeeper.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)
最佳答案
您可以使用以下命令检查 list of topics
可在 Zookeeper
.
bin/kafka-topics.sh --list --zookeeper localhost:2181
还要在
server.properties
中设置以下属性delete.topic.enable=true
然后尝试使用删除主题
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
关于apache-kafka - kafka-topics.sh ---delete --topic '' testTopic'' 不适用于 kafka V 0.10.1,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40034074/