在 KAFKA 中保持生产者和消费者之间的数据一致性

问：

我有一个java，springboot项目，我使用Kafka进行异步通信。有一个 Kafka 生产者，它执行一些逻辑并将记录保存到数据库中。然后，它引发一个事件，该事件由使用者使用，而使用者又在弹性搜索上为记录编制索引。

但是，如果在索引时发生异常，db 和弹性搜索中的数据之间会出现不一致。

在这些场景中，KAFKA 有没有办法保持数据一致性？或者，我需要自己想出办法吗？

浏览了 kafka 文档，但找不到任何有用的东西。