我尝试创建像这样的kafka主题:
kafka-topics --zookeeper HOST --create --topic TOPIC --partitions 2 --replication-factor 1
得到错误:
ERROR admin.TopicCommand$: org.apache.kafka.common.errors.TopicExistsException: Topic 'TOPIC' already
存在。
删除主题无济于事:
在动物园管理员cli中:
get /brokers/topics
输出:所有主题的列表,包括主题
rmr /brokers/topics/TOPIC
无输出
get /brokers/topics
输出:仍包括主题的所有主题的列表
如果我尝试删除不存在的主题,则会出现错误:
Node does not exist: /brokers/topics/TOPIC
很抱歉,很快将问题发布,但也许会对其他人有所帮助。在另一台计算机上正在运行一些查询此主题的进程...
一旦我停止,主题已删除。