手动删除Apache Kafka topic

在Apache的Kafka的最后几个版本中,删除一个主题相当容易。您只需将配置中的一个属性设置为“true”,然后发出删除主题的命令。它很快就会被删除。但是有时候,出于一些我们这样的普通人所不知道的原因,一个话题的删除不会自动发生。如果这种情况发生在你身上,不要着急;还有另一种删除主题的简单方法。

首先,让我们看看如何配置Kafka来删除一个只有命令的主题。' cd '到Kafka安装目录,然后到' config '目录。在这里,您可以找到一个服务器。属性文件(如果已重命名副本,则文件名可能不同)。在你最喜欢的文本编辑器中打开属性文件,对我来说它是Vim。添加以下行,或将属性值更改为true:

delete.topic.enable = true

现在转到“bin”目录,在那里您将找到一个名为“kafka-topic .sh”的文件。

./kafka-topics.sh  --zookeeper localhost:2181 --delete --topic <topic_name>

使用Zookeeper手动删除一个主题

发出删除命令后,主题将被标记为“删除”,您必须等待它被删除。有时,它不会发生。当你遇到这个问题时,你可以使用Zookeeper删除一个主题。首先,使用正确的“zkCli”登录到Zookeeper CLI控制台。sh '文件,你会在Zookeeper安装的“bin”目录中找到它。
一旦你在,确保没有删除主题, 使用以下命令:

get /brokers/topics/<topic_name>

如果您没有得到一个错误,这意味着主题还没有被删除。现在运行以下两个命令从系统中完全删除主题:

rmr /brokers/topics/<topic_name>
rmr /admin/delete_topics/<topic_name>
kafkatcat:一个kafka客户端神器
负载均衡算法有哪些