问题描述
我正在尝试创建一个Spring Boot应用程序（java），该应用程序必须能够通过提供其偏移号和分区来从kafka主题中删除消息。 我一直在研究可以做到这一点的java或spring boot包类，但是我只发现了以下内容： Delete Messages from a Topic in Apache Kafka 有一个java kafka客户端，它具有一种在偏移量之前删除所有消息的方法，但我只是删除一个。 有可能吗？
预先感谢
解决方法
如果仅具有偏移量编号和分区，并且仅可以删除该偏移量处的记录，则不能保证所有使用者均具有最终一致的视图，因此这不是标准操作。 / p>
建议：用相同的键写一条新记录，而空正文可以充当一个事件，告诉所有使用者记录被删除。
正文为空的记录将保留在删除保留时间中配置的主题中。这通常比正常保留时间更长，以确保使用者有足够的时间删除过时的记录。删除保留时间到期后，日志压缩将同时删除原始记录和空记录。