Kafka 中的 CommitSync

Question

我在 Kafka 中处理消息后使用 commitSync()。我想知道 commitSync() 在引发错误之前尝试提交了多少时间？如果它给出错误，那么稍后会再次轮询相同的消息还是假设它已被使用？

Answer 1

如果您没有指定超时，commitSync() 会在 default.api.timeout.ms 指定的时间内阻塞。默认为 60 秒。

如果失败，该消费者实例将不会再次轮询相同的消息，它正在考虑消费。

但是，如果该消费者实例崩溃，使用同一消费者组的新实例将从上次成功提交的位置重新启动。