RMQ

a cli for Apache RocketMQ to manage topics, groups, clusters, acls, brokers, etc.

Features

• topic
  • create
  • list
  • produce
  • describe
  • delete
  • update
• group
  • create
  • list
  • delete
  • update
  • resetOffset
  • describe
  • consume
• message
  • query
• namesrv
  • config
• broker
  • list
  • config

How to use

• Create a rocketmq config file ~/.config/rmq/rmq.yaml:

AccessKey: rocketmq2
SecretKey: 12345678
NamesrvAddrs: 127.0.0.1:9876

• Create a topic:

rmq topic create -t TopicTest -b 127.0.0.1:10911

• Describe a topic:

rmq topic describe -t TopicTest

• List all topics:

rmq topic list

• Produce a message:

rmq topic produce -t TopicTest

• Create a group:

rmq group create -g GroupTest

• List all groups:

rmq group list

• Consume a message:

rmq group consume -g GID_Test -t TopicTest