如何理解RocketMQConsumer命令

本篇文章给大家分享的是有关如何理解RocketMQ Consumer命令，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。

为麻阳等地区用户提供了全套网页设计制作服务，及麻阳网站建设行业解决方案。主营业务为成都做网站、网站建设、麻阳网站设计，以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

1.创建订阅组

bin/mqadmin updateSubGroup -n localhost:9876 -c DefaultCluster -g zto-tst-consumer

2.删除订阅组

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地址

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.查看消费组情况

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

以上就是如何理解RocketMQ Consumer命令，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。