Kafka-自动提交是在后台还是作为轮询循环的一部分发生的



我知道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上的后台。请确认

  1. 尽管没有调用池,但自动提交是否正好在后台@auto.commit.interval.ms发生

我有完全相同的问题。我看到"背景中"的东西在很多地方弹出,这很令人困惑。我能找到的最好的解释是:https://docs.confluent.io/platform/current/clients/consumer.html#message-处理

最新更新