消费者什么时候提交抵消？
When does the consumer commit offset?
我正在使用 spring-kafka-2.2.7-RELEASE。我正在使用@KafkaListener 来创建我的消费者。
我已将 enable.auto.commit 设置为真，将 auto.commit.interval.ms 设置为 10,000（即 10 秒）。现在我的问题是 - 消费者是否为每条记录提交偏移量，或者它是否提交并根据它在 10 秒内消耗的记录数来推进偏移量？
我们通常不建议使用 auto.commit.enabled=true；让容器使用 BATCH 或 RECORD AckModes 进行提交更具确定性（分别在下一个 poll() 之前或处理每条记录之后）。
在 2.3 版本中，我们默认禁用自动提交（除非在配置中明确设置）。
使用自动提交，我的理解是如果自上次轮询以来间隔已经过去，提交将在 poll() 期间发生。它将提交自上次提交以来先前处理过的每个分区的最新偏移量。
我正在使用 spring-kafka-2.2.7-RELEASE。我正在使用@KafkaListener 来创建我的消费者。
我已将 enable.auto.commit 设置为真，将 auto.commit.interval.ms 设置为 10,000（即 10 秒）。现在我的问题是 - 消费者是否为每条记录提交偏移量，或者它是否提交并根据它在 10 秒内消耗的记录数来推进偏移量？
我们通常不建议使用 auto.commit.enabled=true；让容器使用 BATCH 或 RECORD AckModes 进行提交更具确定性（分别在下一个 poll() 之前或处理每条记录之后）。
在 2.3 版本中，我们默认禁用自动提交（除非在配置中明确设置）。
使用自动提交，我的理解是如果自上次轮询以来间隔已经过去，提交将在 poll() 期间发生。它将提交自上次提交以来先前处理过的每个分区的最新偏移量。