我正在使用Spring Kafka 1.2.2.RELEASE。我有一个Kafka侦听器作为使用者,它可以侦听主题并以弹性方式索引文档。我的自动提交偏移量属性设置为true //默认值。
我的印象是,如果侦听器中存在异常(弹性下降),则不应提交偏移量,并且应该为下一次轮询处理相同的消息
但是这没有发生,消费者在下一次轮询时提交偏移量。阅读文章和文档后,我了解到这种情况是将auto commit设置为true到下一次轮询将提交所有偏移量
我的疑问是,消费者为什么要调用下一个民意调查,以及如何通过auto commit为true来防止任何偏移量提交,还是需要将此属性设置为false并手动提交。