V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
slomo
V2EX  ›  Java

获取 rocketmq 积压消息数量

  •  
  •   slomo · 292 天前 · 1374 次点击
    这是一个创建于 292 天前的主题,其中的信息可能已经有所发展或是发生改变。

    目的

    希望获取到 rocketmq 中, 指定消费组中待消费的消息数量。

    目前状态

    可以通过以下方式获取到 topic 中每个 queue 的 maxOffset 和 minOffset ,但是无法获取到当前消费到的 offset

    TopicStatsTable topicStatsTable = mqAdminExt.examineTopicStats(consumerProperties.getTopic());
    topicStatsTable.getOffsetTable().values().stream()
    	.map(topicOffset -> topicOffset.getMaxOffset())
        // do something
    
    5 条回复    2024-01-16 17:12:42 +08:00
    slomo
        1
    slomo  
    OP
       292 天前
    先谢谢各位大佬!
    199808lanlan1111
        2
    199808lanlan1111  
       292 天前 via Android
    从 admin 上可以看到堆积信息,应该可以找到掉的哪个方法
    fenglangjuxu
        3
    fenglangjuxu  
       292 天前 via iPhone
    Promethes 监控可以获取到
    Scarb
        4
    Scarb  
       292 天前
    mqadminExt.examineConsumeStats
    slomo
        5
    slomo  
    OP
       291 天前
    @Scarb 谢谢大佬, 我也找到这个方法了. 可以获取到 brokerOffset, 但是 consumerOffset 一直是 0
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   2735 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 24ms · UTC 12:27 · PVG 20:27 · LAX 05:27 · JFK 08:27
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.