Я пытался создать тему кафки, например:
kafka-topics --zookeeper HOST --create --topic TOPIC --partitions 2 --replication-factor 1
получил ошибку:
ERROR admin.TopicCommand$: org.apache.kafka.common.errors.TopicExistsException: Topic 'TOPIC' already
существует.
удаление темы не помогло так:
в zoo keeper cli:
get /brokers/topics
вывод: список всех тем, включая TOPIC
rmr /brokers/topics/TOPIC
без вывода
get /brokers/topics
вывод: списоквсе темы, которые все еще включают в себя темы
, если я пытаюсь удалить тему, которая не существует, я получаю сообщение об ошибке:
Node does not exist: /brokers/topics/TOPIC