0

为什么在通过此命令删除 Kafka 中的一个主题时：

/opt/kafka/confluent-4.0.0/bin/kafka-topics --zookeeper 109.169.xxx.xx:2181  --delete --topic test

再次查看主题列表，出现此消息？

test - marked for deletion
4

2 回答 2

2

如果很长一段时间后您的主题没有被删除，请确保将delete.topic.enableinserver.properties设置为true（尽管 confluent 4.0.0 带有此配置）。如果您仍然遇到同样的问题，您可以使用登录 Zookeeper 手动删除主题

zookeeper-shell localhost:2181

现在您可以使用删除主题

rmr /brokers/topics/{topic_name}
rmr /admin/delete_topics/{topic_name}

请注意，您可能需要在登录 ZK 之前从 Kafka 代理机器中删除主题文件夹，以便手动删除主题。

于 2018-04-17T09:00:29.593 回答
2

在 Kafka 中，主题删除是异步的。当您使用 运行该kafka-topics工具时--delete，您只是将主题标记为删除。

在大多数情况下，实际删除发生在不久之后，但根据集群的状态，它可能会延迟。

万一它卡住了，弹跳控制器通常会有所帮助。

于 2018-04-17T08:33:57.293 回答