根据kafka文档,consumer config 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。
原因是什么?请帮帮我。
1条答案
按热度按时间dzhpxtsq1#
kafka streams不允许用户设置
enable.auto.commit
. streams使用自己的机制来提交偏移量,而不是依赖使用者自动提交功能。这是为了确保提交只在库确定不会丢失数据的特定点执行。唯一可以控制的提交设置是
commit.interval.ms
.