无法从kafka中删除主题

thigvfpy 于 2021-06-08 发布在 Kafka

关注(0)|答案(4)|浏览(581)

即使在server.config中启用delete.topic.enable=true之后，主题的删除也不起作用。我在重新创建主题时遇到以下错误

Topic 'test' already exists.
[2017-05-23 06:47:05,757] ERROR 
org.apache.kafka.common.errors.TopicExistsException: Topic 'test' already exists.

4条答案

使用主题时不能删除它。使用 bin/kafka-consumer-groups.sh 还是简单 ps -aux|grep Consumer 查找阻止操作的任何可能的使用者。

删除zookeeper中的元数据

./bin/zookeeper-shell.sh localhost:2181
rmr /brokers/topics/mytopic
rmr /admin/delete_topics/mytopic

如果zookeeper是独立示例（不在localhost上），则标记为删除主题不会正确删除它。
一个建议是使用zookeeper展商，并将其从管理员和经纪人中删除。
参展商提供了一个用户界面来可视化主题和Kafka经纪人是如何安排的。

如果你使用最新的Kafka（v~0.10.）然后启用 delete.topic.enable=true 您必须选择：
重启Kafka
删除主题：

kafka-topics.sh --zookeeper localhost:2181 --topic mytopic --delete

检查是否标记为删除：

kafka-topics.sh --zookeeper localhost:2181 --list
mytopic - marked for deletion

再等等。
如果你使用Kafka的旧版本，那么试着从zookeeper shell中删除这个主题。