rocket mq 查看消费进度,消息堆积,清除堆积数据命令

1.查看消费者下 topic 消费进度

broker offset 相当于是消息生产位点,consumer offset 是消息消费位点. 如果两者差异过大,新增的数据就不会实时看到. diff 是剩余未消费消息

sh mqadmin consumerProgress -n localhost:9876 -g PushConsumer

2.查看生产者消费进度

sh mqadmin consumerProgress -n localhost:9876

model 是 集群 ,tps是每秒消费数量, type 消费方式,group 是消费者组

 3.清除堆积数据,这里不是清除而是重置消费位点,效果一样. 未消费的消息rocketmq三天后默认丢弃

sh mqadmin resetOffsetByTime -n localhost:9876 -g PushConsumer -t Topic_EqScanRecord -s -1

命令执行目录就是mq安装位置的bin目录下

标签：消费,rocket,mqadmin,sh,mq,9876,位点,localhost,堆积
来源： https://www.cnblogs.com/onlyzhangmeng/p/16199852.html