kafka同个主题,有2个消费者组,其中一个消费到消息了,另一个消费不到,是在增加应用节点和分区发生的

渊虹 发表于: 2025-08-26   最后更新时间: 2025-08-26 18:31:44   110 游览

生产环境消费慢 消费者3个,主题A ,分区3,2个消费者组 c1,c2

1、然后增加了一个分区
2、增加一个消费者

auto.offset.reset 配置是 latest
增加之后的现象:

组c1,正常消费消息m1,组c2 没有消费m1

怀疑,增加分区后,新的消息已经在第四个分区了,但是还没来得及消费,假设当前offset为10,

增加消费者后,触发再平衡,节点4开始消费第四个分区的消息,由于配置的auto.offset.reset 配置是 latest,只会触发新收到的消息?

[Consumer clientId=consumer-MECH_VERIFY_LEGAL_group_2-16, groupId=MECH_VERIFY_LEGAL_group_2] Request joining group due to: cached metadata has changed from (version2: {MERCHANT_CHECK_SUCCESS_REPORT_REDO=3, MERCHANT_REPORT=3, MECH_VERIFY_LEGAL=3}) at the beginning of the rebalance to (version17: {MERCHANT_CHECK_SUCCESS_REPORT_REDO=3, MERCHANT_REPORT=3, MECH_VERIFY_LEGAL=4})
发表于 2025-08-26
添加评论

显示某个消费组的消费详情

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group

用该命令查看kafka指定消费组的消费情况。

你的答案

查看kafka相关的其他问题或提一个您自己的问题