Kafkacat:如何删除一个主题或它的所有信息？

Question

我正在寻找一种使用kafkacat删除主题或其所有消息的方法。是可能的，还是唯一的方法是通过列出的脚本这里

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic

Answer 1

根据手册页和github源代码，目前在kafkacat中没有删除主题功能。所以唯一的方法就是使用卡夫卡主题的剧本。

github源代码

手册页

kafkacat是Apache 0.8的通用非JVM生产者和消费者，把它看作是Kafka的netcat。 在生产者模式( -P )中，kafkacat从stdin读取消息，用一个可配置的标记来分隔，并将它们生成到提供的Kafka集群、主题和分区。在使用者模式( -C )中，kafkacat从主题和分区读取消息，并使用配置的消息分隔符将它们打印到stdout。如果没有指定-P或-C，kafkacat尝试根据stdin/stdout类型自动计算模式。kafkacat还提供元数据列表模式( -L )，用于显示Kafka集群及其主题和分区的当前状态。

Answer 2

正如@Naween所指出的，您还可以使用动物园管理员-shell.sh. to或zkCli.sh (在“动物园管理员/垃圾箱”下面找到)来这样做：

列出现有主题：./zookeeper-shell.sh localhost:2181 ls /brokers/topics

删除主题：./zookeeper-shell.sh localhost:2181 rmr /brokers/topics/yourtopic

Answer 3

是的，有可能。

但是首先，您必须启用对所有代理的主题删除。将delete.topic.enable更改为true。默认情况下，它是false (在server.properties文件中)

然后，使用主题删除命令。

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic

如果要永久删除该主题，可以使用“动物园管理员删除”命令。

1. 列出现有主题：./zookeeper-shell.sh localhost:2181 ls /brokers/topics
2. 删除主题：./zookeeper-shell.sh localhost:2181 rmr /brokers/topics/yourtopic