apache-kafka - 从 Kafka 主题中删除所有消息

Question

我见过与此相关的类似问题，但没有找到正确的答案。我只想从 Kafka 主题中删除消息，而不是更改保留超时。我已经安装了kafka_2.11-0.8.2.1并使用 bat 文件在 Windows 上运行它。我想知道我是否可以在不删除整个主题的情况下删除一个主题中发布的所有消息。

标签： apache-kafkaapache-zookeeperkafka-producer-api

Answer 1

你不能用 0.8.2 做到这一点。从 0.11.0 开始，您将获得一个 kafka-delete-records.sh 工具来执行此操作。从 1.1 开始，您甚至可以使用带有 deleteRecords 方法的 Java AdminClient API 以编程方式执行此操作。