小编ris*_*shi的帖子

如果发生故障,Spring Kafka自动提交偏移

我正在使用Spring Kafka 1.2.2.RELEASE。我有一个Kafka侦听器作为使用者,它可以侦听主题并以弹性方式索引文档。我的自动提交偏移量属性设置为true //默认值。

我的印象是,如果侦听器中存在异常(弹性下降),则不应提交偏移量,并且应该为下一次轮询处理相同的消息

但是这没有发生,消费者在下一次轮询时提交偏移量。阅读文章和文档后,我了解到这种情况是将auto commit设置为true到下一次轮询将提交所有偏移量

我的疑问是,消费者为什么要调用下一个民意调查,以及如何通过auto commit为true来防止任何偏移量提交,还是需要将此属性设置为false并手动提交。

spring apache-kafka spring-kafka

4
推荐指数
1
解决办法
4938
查看次数

标签 统计

apache-kafka ×1

spring ×1

spring-kafka ×1