Kafka 中的 CommitSync

Question

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

Answer 1

如果您不指定超时，commitSync() 会阻塞 default.api.timeout.ms 指定的持续时间。默认为 60 秒。

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

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