如何使用命令查看 RocketMQ 消息消费状态
要查看 RocketMQ 所有消息是否被消费,可以使用以下两种方法:
-
使用 RocketMQ 控制台
打开 RocketMQ 控制台,并执行以下命令:
sh bin/mqadmin consumerProgress -n localhost:9876 -g 'group_name'其中,'group_name' 是消费者组的名称。
-
使用命令行
在 Linux 终端中执行以下命令:
sh bin/mqadmin consumerProgress -n localhost:9876 -g 'group_name'其中,'group_name' 是消费者组的名称。
此命令将显示所有消费者组的进度和状态,包括消费者消费的消息总数、消息消费速度、消费者状态等。通过检查消费者组的状态,可以确定 RocketMQ 中的所有消息是否已被消费。
原文地址: https://www.cveoy.top/t/topic/ogml 著作权归作者所有。请勿转载和采集!