kafka-topics.sh --- delete --topic '' testTopic '' не работает для kafka V 0.10.1

Я пытаюсь удалить существующий раздел (я проверил с помощью консоли управления kafka), используя следующую команду;kafka-topics.sh --- delete --topic '' testTopic '' не работает для kafka V 0.10.1

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

Но он говорит, тема не доступна в зоопарке. [1 ]

Я создаю эти темы во время выполнения. (Я использую Highlevel Client 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 Нет вывода для указанной команды. Значит, моя тема не в зоопарке? Итак, где темы создаются в 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 - коэффициент повторения 1 - разделы 1 '. Тема находится под '/ brokers/themes' в zk, и команда, указанная выше, может быть напечатана. Я думаю, вы можете попытаться создать тему, используя команду, если вы не пробовали. – 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 --- delete --topic '' testTopic '' не работает для kafka V 0.10.1

ответ

Смежные вопросы