前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >RocketMQ Consumer命令【实战笔记】

RocketMQ Consumer命令【实战笔记】

作者头像
瓜农老梁
发布2019-08-05 14:39:35
1.5K0
发布2019-08-05 14:39:35
举报
文章被收录于专栏:瓜农老梁
1.创建订阅组
代码语言:javascript
复制
bin/mqadmin updateSubGroup -n localhost:9876 -c DefaultCluster -g zto-tst-consumer
2.删除订阅组
代码语言:javascript
复制
bin/mqadmin deleteSubGroup -n 192.168.1.x:9876 -c AdpMqCluster -g CODCANCELSIGN
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10911] in cluster [AdpMqCluster] success.
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10911] in cluster [AdpMqCluster] success.
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10919] in cluster [AdpMqCluster] success.
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10915] in cluster [AdpMqCluster] success.
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10915] in cluster [AdpMqCluster] success.
delete subscription group [CODCANCELSIGN] from broker [192.168.1.x:10919] in cluster [AdpMqCluster] success.
delete topic [%RETRY%CODCANCELSIGN] from cluster [xMqCluster] success.
delete topic [%RETRY%CODCANCELSIGN] from NameServer success.
delete topic [%DLQ%CODCANCELSIGN] from cluster [xMqCluster] success.
delete topic [%DLQ%CODCANCELSIGN] from NameServer success.
3.查看消费组情况及IP地址
代码语言:javascript
复制
bin/mqadmin consumerStatus -g TraceToCaiNiao -n 192.168.1.x:9876
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
001 192.168.12.122@25063 V3_5_8 1539756615406/192.168.x.x@25063
002 192.168.13.96@3351 V3_5_8 1539756615406/192.168.x.x@3351
003 192.168.x.x@13385 V3_5_8 1539756615406/192.168.x.x@13385
004 192.168.x.x@6691 V3_5_8 1539756615406/192.168.x.x@6691
4.查看消费组情况
代码语言:javascript
复制
bin/mqadmin consumerProgress -n 192.168.1.x:9876 -g SortComplementConsumer
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0
Topic Broker Name QID Broker Offset Consumer Offset Diff LastTime
%RETRY%SortComplementConsumer broker-a 0 1 1 0 2018-10-22 12:43:13
%RETRY%SortComplementConsumer broker-b 0 2 2 0 2018-10-22 12:43:13
%RETRY%SortComplementConsumer broker-c 0 2 2 0 2018-10-22 12:43:28
%RETRY%SortComplementConsumer broker-d 0 2 2 0 2018-10-22 12:44:33
SCANRECORD broker-a 0 39717505 39717502 3 2018-10-22 13:53:21
SCANRECORD broker-a 1 39721504 39721502 2 2018-10-22 13:53:21
SCANRECORD broker-a 2 39733704 39733703 1 2018-10-22 13:53:21
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2019-07-20,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 瓜农老梁 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1.创建订阅组
  • 2.删除订阅组
  • 3.查看消费组情况及IP地址
  • 4.查看消费组情况
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档