H5W3
当前位置:H5W3 > 其他技术问题 > 正文

RocketMQ生产消息异常(在线等…..)

首先错误代码如下

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Message [topic=TopicA, flag=0, properties={KEYS=key, WAIT=true, TAGS=tagA}, body=21]
org.apache.rocketmq.client.exception.MQClientException: Send [3] times, still failed, cost [7238]ms, Topic: TopicA, BrokersSent: [broker-a, broker-a, broker-a]
See http://rocketmq.apache.org/docs/faq/ for further details.
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:541)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1058)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1017)
    at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:208)
    at com.alex.rocket.Producer.main(Producer.java:36)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <10.0.2.15:10911> failed
    at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:359)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:349)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:333)
    at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:296)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:693)
    at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:460)
    ... 4 more

生产者代码如下
图片描述

broker.log如下
图片描述

nameser.log如下
图片描述
图片描述

broker.conf如下
图片描述

在线等….

回答:

@Avro 是这个东西…很奇怪啊
图片描述

本文地址:H5W3 » RocketMQ生产消息异常(在线等…..)

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址