基于版本 4.4.0 官网链接 源码链接
文章目录
- 命令执行方式
- Topic
- 主题列表
- 更新或创建主题
- 删除主题
命令执行方式 在源码根目录下 执行命令
sh bin/mqadmin $command $optkey $optvalue ...
Topic 主题列表 Description: Fetch all topic list from name server
Command: topicList
Class: TopicListSubCommand
Options:
opt | longOpt | required | default | description |
---|---|---|---|---|
n | true | namesrv 地址 | ||
c | clusterModel | false | 声明 -c 将列出集群名称信息和消费者组信息 |
sh bin/mqadmin topicList -n 172.17.0.2:9876 -c
更新或创建主题 Description: Update or create topic
Command: updateTopic
Class: UpdateTopicSubCommand
Options:
opt | longOpt | required | default | description |
---|---|---|---|---|
n | true | namesrv 地址 | ||
b | brokerAddr | false | 在指定 broker 创建 | |
c | clusterName | false | 在集群内所有 broker 创建,b 和 c 至少包含一个,同时存在 b 生效, | |
t | topic | true | 指定主题名称 | |
r | readQueueNums | false | 8 | 设置读队列的个数 |
w | writeQueueNums | false | 8 | 设置写队列的个数 |
p | perm | false | 6 | 设置主题权限(2:W 4:R; 6:RW) |
o | order | false | false | 是否为顺序消息主题 |
u | unit | false | false | 是否为 Unit 主题 (未启用) |
s | hasUnitSub | false | false | 是否包含子 Unit (未启用) |
sh bin/mqadmin updateTopic -n 172.17.0.2:9876 -c CustomizeCluster -t ISHOUJING
删除主题 Description: Delete topic from broker and NameServer.
Command: deleteTopic
Class: DeleteTopicSubCommand
Options:
opt | longOpt | required | default | description |
---|---|---|---|---|
n | true | namesrv 地址 | ||
c | clusterName | true | 移除指定集群名称下的主题 | |
t | topic | true | 指定主题名称 |
sh bin/mqadmin deleteTopic -n 172.17.0.2:9876 -c CustomizeCluster -t ISHOUJING
推荐阅读
- RocketMQ - 理论篇
- RocketMQ - 应用篇
- RocketMQ-单机版安装及远程连接测试
- RocketMQ安装及测试
- RocketMQ原理
- Kafka|Kafka VS RocketMQ VS RabbitMQ
- RocketMQ
- RocketMQ遇到的坑
- Rocketmq创建topic报错org.apache.rocketmq.acl.common.AclException: [10015:signature-failed] unable to cal