我已经将enable.auto.commit设置为true,并将auto.commit.interval.ms设置为10,000(即10秒)。现在我的问题是--如果使用者在第一次轮询时得到100条记录,而监听器正在处理一条一条的记录,而它在10秒内只处理了80条记录,它是提交并将偏移提前80还是100?
提交的偏移量将是轮询的金额,而不是处理的金额。
如果您想要确认轮询中的所有记录都已处理,那么您需要禁用自动提交并自己执行
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或者根据公司服务器时间设置时间