Replies: 1 comment
-
https://github.com/apache/rocketmq/wiki/RIP-48-Enhance-server-side-offset-management-ability 中提到以下内容: 我想请教2个问题: 以下是我的个人理解,请问是否正确? 在这种机制下,一个消费组如果发生了广播消费,则这个消费组会以这个广播消费开始的offset记录消费进度中的 Diff/Delay 信息,也就是说只要这个消费组发生过广播消费,通过mqadmin consumerProgress查看到的 Diff Total就会随着消息的发布而无限增长,如果想让Diff/Delay归零必须要发生以下两种情况: |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
在 #9354 中提到了RocketMQ 5.3 中广播消费的消费组中记录了Diff/Delay信息的问题,这个和RocketMQ4是不一样的,如下图:
根据
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将随着消息的发布而无限变大,除非出现以下两种情况:
请问这是否时合理的设计?Diff计数无限变大不会出现数据溢出么?
Beta Was this translation helpful? Give feedback.
All reactions