enable.auto.commit 值未配置为 true

Question

根据 Kafka 文档，消费者配置 enable.auto.commit 的默认值为 true。但我越来越假了。

在我的 Kafka 流应用程序中，我尝试将其更改为 true 为 props.put(StreamsConfig.consumerPrefix(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG), true) 以自动提交偏移量。但我在日志中收到 WARN o.a.k.s.StreamsConfig [main] Unexpected user-specified consumer config: enable.auto.commit found. User setting (true) will be ignored and the Streams default setting (false) will be used 消息并恢复为 false。

原因是什么？请帮帮我。

Answer 1

Kafka Streams 不允许用户设置enable.auto.commit。 Streams 使用自己的机制来提交偏移量，而不是依赖于消费者自动提交功能。这是为了确保只在库确定不会丢失数据的特定时间点完成提交。

您可以控制的唯一提交设置是commit.interval.ms。