一个简简单单的 RocketMQ 的 Java 测试程序发送消息失败,错误信息如下:
org.apache.rocketmq.client.exception.MQClientException: The producer service state not OK, CREATE_JUST
RocketMQ 服务正常,用其自带的测试可以成功。
是什么原因呢?
一个简简单单的 RocketMQ 的 Java 测试程序发送消息失败,错误信息如下:
org.apache.rocketmq.client.exception.MQClientException: The producer service state not OK, CREATE_JUST
RocketMQ 服务正常,用其自带的测试可以成功。
是什么原因呢?
找到原因了,是我自己的锅,忘了调用 .start() 方法了
RocketMQ 什么版本?