kafka-topics.sh ---delete --topic ''testTopic'' 不适用于 kafka V 0.10.1答案

【问题标题】：kafka-topics.sh ---delete --topic ''testTopic'' is not working for kafka V 0.10.1kafka-topics.sh ---delete --topic ''testTopic'' 不适用于 kafka V 0.10.1
【发布时间】：2017-02-23 08:23:05
【问题描述】：

我尝试使用以下命令删除现有主题（我使用 kafka 管理控制台检查过）；

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

但它说主题在 zookeeper 中不可用。[1]

我在运行时创建这些主题。（我使用 Highlevel Client APIs。我认为它是在 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)

【问题讨论】：

主题是否存在？ ./bin/kafka-topics.sh --zookeeper 127.0.0.1:2181/chroot --topic testTopci --describe
@louxiu 上述命令无输出。意味着我的主题不在 zookeeper 中？那么，kafka 0.10 中的主题是在哪里创建的呢？
不确定 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 问题是我在 zookeeper 参数末尾有“/chroot”。没有它现在工作正常。

标签： apache-kafka

【解决方案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

【讨论】：

这行得通。谢谢。问题是我最后有“/chroot”。这就是文档kafka.apache.org/documentation.html#basic_ops_modify_topic 中提到的方式
在最新版本中 --zookeeper 被 --bootstrap-server 取代。通过改变它，这只对我有用。

【解决方案2】：

如果下面的命令对你不起作用

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

您可以通过连接zookeeper并删除路径来手动删除。

./zookeeper-shell.sh

手动删除主题

rmr /brokers/topics/<topic>

【讨论】：

已弃用