RocketMQ中Connection命令怎么用

发布时间:2021-11-18 09:10:49 作者:小新
来源:亿速云 阅读:186

这篇文章主要为大家展示了“RocketMQ中Connection命令怎么用”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“RocketMQ中Connection命令怎么用”这篇文章吧。

 1.消费端连接信息

bin/mqadmin consumerConnection -g T_SCANRECORD_NEW_GROUP -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 127.0.0.1@60190 192.168.2.x:50104 JAVA V3_2_6_SNAPSHOT
002 127.0.0.1@7454 192.168.7.x:27692 JAVA V3_2_6_SNAPSHOT
003 127.0.0.1@31600 192.168.21.x:40243 JAVA V3_2_6_SNAPSHOT
004 127.0.0.1@21322 192.168.21.x:31416 JAVA V3_2_6_SNAPSHOT
005 127.0.0.1@39557 192.168.2.x:45959 JAVA V3_2_6_SNAPSHOT
006 127.0.0.1@24765 192.168.7.x:15166 JAVA V3_2_6_SNAPSHOT
007 127.0.0.1@26993 192.168.7.x:57864 JAVA V3_2_6_SNAPSHOT
008 127.0.0.1@652 192.168.21.x:59261 JAVA V3_2_6_SNAPSHOT
009 127.0.0.1@10388 192.168.21.x:1671 JAVA V3_2_6_SNAPSHOT
Below is subscription:001 Topic: %RETRY%T_SCANRECORD_NEW_GROUP SubExpression: *
002 Topic: T_SCANRECORD_NEW SubExpression: 1||2||3||4 || 5 || -5||7 || 45
ConsumeType: CONSUME_PASSIVELY
MessageModel: CLUSTERING
ConsumeFromWhere: CONSUME_FROM_FIRST_OFFSET

   2.生产连接信息

bin/mqadmin producerConnection -t T_SCANRECORD_NEW -g producetGroup -n 192.168.1.x:9876

以上是“RocketMQ中Connection命令怎么用”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

推荐阅读:
  1. RocketMQ
  2. Java中Connection timed out与Connection refused有什么区别

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

rocketmq connection

上一篇:如何深入剖析DIV标签的使用

下一篇:十个不为人知的CSS技巧分别是什么

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》