要查看 RocketMQ 所有消息是否被消费,可以使用以下两种方法:

  1. 使用 RocketMQ 控制台

    打开 RocketMQ 控制台,并执行以下命令:

    sh bin/mqadmin consumerProgress -n localhost:9876 -g 'group_name'
    

    其中,'group_name' 是消费者组的名称。

  2. 使用命令行

    在 Linux 终端中执行以下命令:

    sh bin/mqadmin consumerProgress -n localhost:9876 -g 'group_name'
    

    其中,'group_name' 是消费者组的名称。

    此命令将显示所有消费者组的进度和状态,包括消费者消费的消息总数、消息消费速度、消费者状态等。通过检查消费者组的状态,可以确定 RocketMQ 中的所有消息是否已被消费。

如何使用命令查看 RocketMQ 消息消费状态

原文地址: https://www.cveoy.top/t/topic/ogml 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录