我使用了一个Kafka主题，它的元数据以及我的应用程序。我通过删除与该主题对应的目录，从zookeeper shell中硬删除了该主题。再次创建主题后，我描述了主题，发现没有为这个新创建的主题分配任何领导。在消费者中，我可以看到重复打印的日志 LEADER_NOT_AVAILABLE . 有什么理由说明我做错了什么吗？或者有没有一种方法可以删除Kafka主题相关的元数据，但我不知道？提前谢谢！
我使用了一个Kafka主题，它的元数据以及我的应用程序。我通过删除与该主题对应的目录，从zookeeper shell中硬删除了该主题。再次创建主题后，我描述了主题，发现没有为这个新创建的主题分配任何领导。在消费者中，我可以看到重复打印的日志 LEADER_NOT_AVAILABLE . 有什么理由说明我做错了什么吗？或者有没有一种方法可以删除Kafka主题相关的元数据，但我不知道？提前谢谢！
1条答案
按热度按时间ymdaylpp1#
直到最近，删除Kafka的主题才变得简单。一般来说，您不应该试图通过删除zookeeper中的元数据来删除kafka主题。您应该始终使用附带的命令行实用程序。
首先，您需要确保在中启用了删除主题
server.properties在所有代理上归档，并在需要时执行滚动重新启动：重新启动代理以启用主题删除后，应发出
delete使用命令行实用程序的命令：如果此时仍然卡住，请尝试从zookeeper shell运行以下两个命令，以确保并删除该特定主题的所有元数据：
这里还有一些细节：
https://medium.com/@contactsunny/manually-删除-apache-kafka-topics-424c7e016ff3