centos上通过命令创建rocketmq的topic
时间: 2024-06-12 21:05:23 浏览: 105
在CentOS上创建RocketMQ的topic,需要先安装RocketMQ。安装方法可参考官方文档:https://rocketmq.apache.org/docs/quick-start/
以下是通过命令创建RocketMQ的topic的步骤:
1. 启动namesrv和broker服务:
```
nohup sh bin/mqnamesrv &
nohup sh bin/mqbroker -n localhost:9876 &
```
2. 创建topic:
```
sh bin/mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t TopicTest
```
其中,-n参数指定namesrv地址,-c参数指定集群名称,-t参数指定topic名称。
3. 查看topic:
```
sh bin/mqadmin topics -n localhost:9876
```
该命令将列出所有已创建的topic。
4. 删除topic:
```
sh bin/mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t TopicTest
```
该命令将删除指定的topic。
相关问题
centos使用nohup命令启动RocketMQ broker提示:nohup: ignoring input and appending output to ‘nohup.out’
这个提示是因为 nohup 命令会将标准输出和标准错误输出重定向到 nohup.out 文件中,而忽略输入。如果你想要在后台启动 RocketMQ broker,可以使用以下命令:
```
nohup sh bin/mqbroker -n localhost:9876 &
```
这样就可以将 RocketMQ broker 启动在后台,并将输出重定向到 nohup.out 文件中。
centOS中rocketmq查询队列用命令
在 CentOS 中,可以使用以下命令来查询 RocketMQ 队列:
1. 列出所有的 topic:
```
./mqadmin topicList -n localhost:9876
```
其中,`localhost:9876` 是 RocketMQ 的地址和端口。
2. 查询指定 topic 的队列信息:
```
./mqadmin queryTopicConsumeByWho -t topic_name -n localhost:9876
```
其中,`topic_name` 是要查询的 topic 名称。
3. 查询指定消费者组的消费情况:
```
./mqadmin consumerProgress -g consumer_group_name -n localhost:9876
```
其中,`consumer_group_name` 是要查询的消费者组名称。
4. 查询指定队列的堆积情况:
```
./mqadmin queryMsgById -i message_id -n localhost:9876
```
其中,`message_id` 是要查询的消息 ID。
以上是一些常用的 RocketMQ 查询命令,可以根据实际情况进行选择使用。
阅读全文