生产环境消费慢 消费者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})
显示某个消费组的消费详情
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
用该命令查看kafka指定消费组的消费情况。
你的答案