为什么使用此命令删除Kafka中的一个主题：
/opt/kafka/confluent-4.0.0/bin/kafka-topics --zookeeper 109.169.xxx.xx:2181 --delete --topic test
再次看到主题列表，这个消息出现了吗？
test - marked for deletion
wwtsj6pe1#
在kafka中，主题删除是异步的。当你运行 kafka-topics 工具 --delete ，您只是将主题标记为删除。在大多数情况下，实际的删除会在之后不久发生，但根据集群的状态，删除可能会延迟。万一它卡住了，反弹控制器通常会有帮助。
kafka-topics
--delete
izj3ouym2#
如果很长一段时间后你的主题没有被删除，那么请确保 delete.topic.enable 在 server.properties 设置为 true （尽管Confluent4.0.0附带了此配置）。如果您仍然面临相同的问题，您可以通过使用登录zookeeper手动删除主题
delete.topic.enable
server.properties
true
zookeeper-shell localhost:2181
现在可以使用
rmr /brokers/topics/{topic_name} rmr /admin/delete_topics/{topic_name}
请注意，您可能需要在登录zk之前从kafka代理计算机中删除主题文件夹，以便手动删除主题。
2条答案
按热度按时间wwtsj6pe1#
在kafka中，主题删除是异步的。当你运行
kafka-topics工具--delete，您只是将主题标记为删除。在大多数情况下，实际的删除会在之后不久发生，但根据集群的状态，删除可能会延迟。
万一它卡住了，反弹控制器通常会有帮助。
izj3ouym2#
如果很长一段时间后你的主题没有被删除，那么请确保
delete.topic.enable在server.properties设置为true（尽管Confluent4.0.0附带了此配置）。如果您仍然面临相同的问题，您可以通过使用登录zookeeper手动删除主题现在可以使用
请注意，您可能需要在登录zk之前从kafka代理计算机中删除主题文件夹，以便手动删除主题。