Kafkacat：如何删除主题或其所有消息？

Question

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

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

Answer 1

根据手册页和 github 源代码，kafkacat 目前没有删除主题功能。所以唯一的办法就是使用kafka-topics脚本。

github source code

man page

kafkacat is a generic non-JVM producer and consumer for Apache Kafka 0.8, think of it as a netcat for Kafka.

 In producer mode ( -P ), kafkacat reads messages from stdin, delimited with a configurable
 delimeter and produces them to the provided Kafka cluster, topic and partition. In consumer
 mode ( -C ), kafkacat reads messages from a topic and partition and prints them to stdout
 using the configured message delimiter.

 If neither -P or -C are specified kafkacat attempts to figure out the mode automatically
 based on stdin/stdout tty types.

 kafkacat also features a metadata list mode ( -L ), to display the current state of the
 Kafka cluster and its topics and partitions.

Answer 2

是的，有可能。

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

那么，使用主题删除命令。

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

如果您想永久删除该主题，可以使用zookeeper删除命令。

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

Answer 3

正如@Naween Banuka 指出的那样，您还可以使用 zookeeper-shell.sh 或 zkCli.sh（在 zookeeper/bin 下找到）来执行此操作：

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

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

Kafkacat：如何删除主题或其所有消息？

Kafkacat: how to delete a topic or all its messages?

apache-kafka

kafkacat