Spring Kafka Acknowledgement.acknowledge 线程安全吗？

Question

我正在实现一个基于 kafka 的应用程序，我想在其中手动确认收到的消息。架构迫使我在一个单独的线程中完成它。

问题是:在与消费者不同的线程中执行 Acknowledgement.acknowledge() 是否可能且安全？

Answer 1

是的，只要您使用 MANUAL 而不是 MANUAL_IMMEDIATE，但我认为您不会得到预期的结果。

Kafka 不跟踪每条消息，只跟踪分区内的偏移量。

假设消息 1 到达，您将其移交给另一个线程。然后消息 2 到达，它被传递给另一个线程。

当消息 2 的偏移量被确认时，您实际上是在确认这两条消息。