kafka-topics.sh ---删除--topic''testTopic''不适用于kafka V 0.10.1

我尝试使用以下命令删除现有主题（我使用kafka管理控制台进行了检查）;kafka-topics.sh ---删除--topic''testTopic''不适用于kafka V 0.10.1

＃。/ kafka-topics.sh --zookeeper zookeeper.xx.com:2181/chroot --delete --topic testTopic

但它说，在动物园管理员不可用主题。[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)

来源

2016-10-14 Ratha

是否存在的话题的话题？ './bin/kafka-topics.sh --zookeeper 127.0.0.1:2181/chroot --topic testTopci --describe' – louxiu

@louxiu上述命令没有输出。意味着我的话题不在zookeeper中？那么，哪些主题是在kafka 0.10中创建的？ – Ratha

不确定是否为0.10.1，我在0.9.0.1中试过这个'./bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --topic test_kafka123 --replication-factor 1 --partitions 1 '。该主题在zk和上面的命令中的'/ brokers/topics'下可以打印。我想你可以尝试使用命令创建主题，如果你还没有尝试过。 – louxiu

您可以使用下面的命令检查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

来源

2016-10-14 05:05:45 Shankar

这工作。谢谢。问题是我在最后得到了“/ chroot”。这就是在文档http://kafka.apache.org/documentation.html#basic_ops_modify_topic中提到的方式 – Ratha

kafka-topics.sh ---删除--topic''testTopic''不适用于kafka V 0.10.1

回答

相关问题