可能性1:
可能是由于mq没启动成功
进入对应bin目录,修改文件runserver.sh runbroker.sh。 把VM参数都改成
-Xms256m -Xmx256m -Xmn128m
或者你想要的大小。默认给的8G,如果不改,很可能启动不成功。
4、启动 NameServer。
nohup sh bin/mqnamesrv & .
查看是否启动成功
jps
查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
5、启动 BrokerServer。
nohup sh bin/mqbroker -n localhost:9876 & .
查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
6、关闭服务。
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
可能性2:
Broker 禁止自动创建Topic,且用户没有通过手动创建此Topic,或者broker 和 Nameserver网络不通
二、解决方案:
修改broker.properties配置,自动创建topic,添加如下:
autoCreateTopicEnable=true
官方文档中启动 Broker是这样的:
nohup sh bin/mqbroker -n localhost:9876 &
其实我们可以改成这样:
nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &