我在多节点多集群环境中设置了kafka版本2.11-0.10.1.0 . 在kafka server.properties中,我已经在所有3台机器中添加了 delete.enable.topic=true .
我正在使用命令删除主题是, ./bin/kafka-topic.sh --zookeeper ip1:2181,ip2:2181,ip3:2181 --delete --topic topicname
但它没有删除,显示 topic name -mark for deletion
因此,每次我清除kafka-logs和zookeeper日志以进行删除主题 .
任何人都有任何想法使用命令提示符删除 .
1 回答
一般来说,你所做的一切听起来都是正确的,我怀疑你的问题是一个简单的错字 .
在Kafka中启用主题删除的参数称为:delete.topic.enable not,如上所述:delete.enable.topic .
这将导致删除恢复为其默认值,该值为false并导致您看到的行为 .
更正此问题并重新启动应解决您的问题并删除所有主题 .