apache-kafka - 从 kafka 主题中删除单个记录

Question

有没有办法从 kafka 主题中删除一条记录？我知道有脚本 kafka-delete-records.sh 删除指定主题和分区上指定偏移量之前的记录，但我希望能够删除我指定的偏移量上的记录。有没有办法做到这一点？

这不是在 Java 上，而是在裸卡夫卡实例上。

标签： apache-kafka

Answer 1

在压缩的主题上，您可以通过发布消息来将记录标记为“墓碑”，以指示您要使用空值删除的键。在这里查看答案：Kafka not delete key with tombstone

如果未压缩主题，则必须通过保留策略删除记录。您不能针对要删除的单个偏移量。