RocketMQLog:WARN No appenders could be found forlogger(io.netty.util.internal.InternalThreadLocalMap). RocketMQLog:WARN Please initialize the logger system properly.
Field rocketMQTemplate in com.sks.crm.service.RocketMQProducerService required a bean of type 'org.apache.rocketmq.spring.core.RocketMQTemplate' that could not be found.
org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14 DESC: service not available now. It may be caused by one of the following reasons: the broker's disk is full [CL:0.92 CQ:0.92 INDEX:0.92], messages are put to the slave, message store has been shut down, etc. BROKER:169.254.87.77:10911
Caused by: org.apache.rocketmq.client.exception.MQClientException: The consumer group[my-consumer] has been created before, specify another name please
原因:
同一个消费者组名已在 RocketMQ 中创建,重复使用。
解决方案:
确保每个消费者组名是唯一的,不要重复使用。
七、配置文件格式问题
1. 配置文件格式错误
报错内容:
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'rocketMQTemplate' defined in class path resource [org/apache/rocketmq/spring/autoconfigure/RocketMQAutoConfiguration.class]: Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.apache.rocketmq.spring.core.RocketMQTemplate]: Constructor threw exception; nested exception is java.lang.IllegalArgumentException: rocketmq.name-server is required.