希望获取到 rocketmq 中, 指定消费组中待消费的消息数量。
可以通过以下方式获取到 topic 中每个 queue 的 maxOffset 和 minOffset ，但是无法获取到当前消费到的 offset
TopicStatsTable topicStatsTable = mqAdminExt.examineTopicStats(consumerProperties.getTopic()); topicStatsTable.getOffsetTable().values().stream() .map(topicOffset -> topicOffset.getMaxOffset()) // do something  | 1 slomo OP 先谢谢各位大佬！ |
 | 2 199808lanlan1111 Jan 15, 2024 via Android 从 admin 上可以看到堆积信息，应该可以找到掉的哪个方法 |
 | 3 keepfun Jan 15, 2024 via iPhone Promethes 监控可以获取到 |
 | 4 Scarb Jan 15, 2024 mqadminExt.examineConsumeStats |
| 5 slomo OP @Scarb 谢谢大佬, 我也找到这个方法了. 可以获取到 brokerOffset, 但是 consumerOffset 一直是 0 |
Select Language