使用者配置-当我们将enable.auto.commit设置为true时，使用者提交何时偏移
我已经将enable.auto.commit设置为true，并将auto.commit.interval.ms设置为10,000（即10秒）。现在我的问题是--如果使用者在第一次轮询时得到100条记录，而监听器正在处理一条一条的记录，而它在10秒内只处理了80条记录，它是提交并将偏移提前80还是100？
共有1个答案
提交的偏移量将是轮询的金额，而不是处理的金额。
如果您想要确认轮询中的所有记录都已处理，那么您需要禁用自动提交并自己执行
-
Spring Kafka-batchListener-true enable.auto.commit-true max_poll_records_config-默认(500) MAX_POLL_INTERVAL_MS_CONFIG-默认值（5分钟）
-
我已经将enable.auto.commit设置为true，并将auto.commit.interval.ms设置为10,000（即10秒）。现在我的问题是--消费者是每个记录的提交偏移量，还是根据10秒内消耗的记录数提交并提前偏移量？
-
当我使用concurrentKafkaListenerContainerFactory时，有什么方法可以设置主题吗？我根本不想做任何注释。
-
我有一个版本1.1.0中的kafka控制台消费者，我用它从kafka获取消息。当我使用带有option-max-messages的kafka-console-consumer.sh脚本时，它似乎提交了错误的偏移量。 我创建了一个主题和一个消费者小组，并阅读了一些消息：
-
当我查看DevicePolicyManager https://developer.android.com/reference/android/app/admin/DevicePolicyManager.html时，我发现了EXTRA_PROVISIONING_LOCAL_TIME，我使用这个常量的查询可以根据设备所有者规范设置时间，比如5月19,2013 15:20或者根据公司服务器时间设置时间