rocketmq-client-java:5.0.7原生API客户端构建生产者报错

rocketmq-client-java:5.0.7原生API客户端构建生产者报错,报错内容如下,请问该如何解决
java.lang.IllegalStateException: Expected the service ProducerImpl-0 [FAILED] to be RUNNING, but the service has FAILED at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:381) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:305) at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:165) at org.apache.rocketmq.client.java.impl.producer.ProducerBuilderImpl.build(ProducerBuilderImpl.java:93) at com.rubbish.dump.start.CommTest.testSendToRocketMQ(CommTest.java:90) at java.base/java.lang.reflect.Method.invoke(Method.java:568) at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) at java.base/java.util.ArrayList.forEach(ArrayList.java:1511) Caused by: java.util.concurrent.ExecutionException: java.lang.IllegalArgumentException: Message type is not specified

展开
收起
游客2hbo6ymhmb2n4 2025-04-23 15:55:58 32 发布于浙江 分享
分享
版权
举报
0 条回答
写回答
取消 提交回答

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

还有其他疑问?
咨询AI助理