【Kafka】【十九】新消费组的消费offset规则

新消费组的消费offset规则

新消费组中的消费者在启动以后，默认会从当前分区的最后⼀条消息的offset+1开始消费（消费新消息）。可以通过以下的设置，让新的消费者第⼀次从头开始消费。之后开始消费新消息（最后消费的位置的偏移量+1）

props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,"earliest");

将消费者消费组改成testGroup1

在这里插入图片描述

直接订阅主题test

在这里插入图片描述

启动后发现没有消费到消息，这是因为新消费组消费主题，是从最新的offset进行消费的

在这里插入图片描述

这时生产者发送消息，新消费组的消费者也可以接收到并消费

新建一个testGroup2的消费组

在这里插入图片描述

然后将配置改为earliest

在这里插入图片描述

启动Consumer后会获取到test主题下所有分区的从0的offset位置以后的所有消息，下次会从已经消费的offset+1位置处开始消费

在这里插入图片描述

标签： kafka java 分布式

本文转载自: https://blog.csdn.net/weixin_41405524/article/details/129002464
版权归原作者 BirdMan98 所有，如有侵权，请联系我们删除。