Java Spring boot kafka使用偏移量从主题中删除消息

Question

我试图创建一个Spring引导应用程序（java），它必须能够通过给它的偏移数和分区从Kafka主题删除消息。我一直在研究java或Spring Boot包类可以做到这一点，但我只发现了这样的东西：从Apache Kafka主题中删除消息有一个java kafka客户端有一个方法来删除所有消息之前一个偏移，但我只是一个删除一个。这是可能的吗？

提前感谢

Answer 1

如果您只有偏移量编号和分区，并且您可以删除该偏移量处的记录，那么您不能保证所有使用者最终都会有一致的视图，所以这就是为什么它不是标准操作的原因。

建议：使用相同的密钥编写一个新记录，空主体可以作为一个事件，告诉所有消费者该记录已被删除。

主体为空的记录将保留在“删除保留时间”中配置的主题中。这通常比正常的保留时间长，以确保消费者有足够的时间删除过时的记录。删除保留时间到期后，原始记录和空记录都将通过日志压缩删除。