GitHub user zergduan edited a discussion: RocketMQ5 广播消费的消费组消费进度的Diff 
Total数据将无限变大?
https://github.com/apache/rocketmq/issues/9354 中提到了RocketMQ 5.3 
中广播消费的消费组中记录了Diff/Delay信息的问题,这个和RocketMQ4是不一样的,如下图:

![image](https://github.com/user-attachments/assets/4608a4de-20ff-430e-b4a7-432134398353)


根据
RIP 48 Enhance server side offset management ability
https://github.com/apache/rocketmq/wiki/RIP-48-Enhance-server-side-offset-management-ability
中的解释,新版本中广播消费的消费组将记录消费进度,并且以第一次发生广播消费的offset来计算Diff 
Total数据;根据我的测试一个消费组只要发生了广播消费,他的消费进度中的Diff Total将随着消息的发布而无限变大,除非出现以下两种情况:
1. 手动reset消费组的消费进度
2. 停止广播消费并开启集群消费,将diff中的消息全部重新消费一遍

请问这是否时合理的设计?Diff计数无限变大不会出现数据溢出么?

GitHub link: https://github.com/apache/rocketmq/discussions/9405

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org

Reply via email to