我知道kafka消费者、提交偏移等。。然而,在这个地方,对自动提交有多种解释。
卡夫卡消费者自动提交是如何工作的?需要澄清Kafka自动提交和auto.commit.interval.ms
发件人https://www.javaworld.com/article/3066873/big-data/big-data-messaging-with-kafka-part-2.html?page=2,
自动提交:您可以将Auto.commit设置为true并设置auto.commit.interval.ms属性,其值以毫秒为单位。一旦如果启用了此功能,Kafka消费者将提交响应其poll((调用而接收的最后一条消息poll((调用在后台以设置的auto.commit.interval.ms发出。
短语-">poll((调用在后台以设置的auto.commit.interval.ms发出";有时似乎自相矛盾,因为事实并非如此。由于自动提交是作为池循环的一部分发生的,而不是在auto.commit.interval.ms上的后台。请确认
- 尽管没有调用池,但自动提交是否正好在后台@auto.commit.interval.ms发生
我有完全相同的问题。我看到"背景中"的东西在很多地方弹出,这很令人困惑。我能找到的最好的解释是:https://docs.confluent.io/platform/current/clients/consumer.html#message-处理