我尝试使用以下命令删除现有主题(我使用kafka管理控制台进行了检查);
./kafka-topics.sh--zookeeper zookeeper.xx。com:2181/chroot --delete—主题testtopic
但它说这个主题在zookeeper中不可用
我在运行时创建这些主题(我使用高级客户端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)
2条答案
按热度按时间jrcvhitl1#
您可以使用下面的命令来检查
list of topics
提供于Zookeeper
.同时在中设置以下属性
server.properties
```delete.topic.enable=true
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
njthzxwz2#
如果下面的命令对你不起作用
您可以通过连接zookeeper手动删除并删除路径。
手动删除主题