连接rocketmq遇到的异常
sendDefaultImpl call timeout
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:640)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1310)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1256)
【rocketmq-连接rocketmq遇到的异常】可能没有连接到broker
No route info of this topic: my-topic
Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: No route info of this topic: my-topic
See http://rocketmq.apache.org/docs/faq/ for further details.
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:684)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1342)
可能没有创建topic,通过mqadmin手动创建
TopicListSubCommand command failed
org.apache.rocketmq.tools.command.SubCommandException: TopicListSubCommand command failed
at org.apache.rocketmq.tools.command.topic.TopicListSubCommand.execute(TopicListSubCommand.java:113)
at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:134)
at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:85)
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to failed
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:392)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.getTopicListFromNameServer(MQClientAPIImpl.java:1252)
at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.fetchAllTopicList(DefaultMQAdminExtImpl.java:222)
at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.fetchAllTopicList(DefaultMQAdminExt.java:189)
可能没有连接broker
DESC: service not available now, maybe disk full
Caused by: org.apache.rocketmq.client.exception.MQBrokerException: CODE: 14DESC: service not available now, maybe disk full,
CL:0.91 CQ: -1.00 INDEX: -1.00, maybe your broker machine memory too small.
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.client.impl.MQClientAPIImpl.processSendResponse(MQClientAPIImpl.java:709)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:505)
可能磁盘不足
推荐阅读
- Kafka|Kafka VS RocketMQ VS RabbitMQ
- RabbitMQ|RabbitMQ 四种类型发送接收数据方式
- mac下安装rabbitmq遇到的坑
- RabbitMQ读写消息的Java Demo
- RabbitMQ 常见面试题
- mac 安装 RabbitMQ
- Go|RabbitMQ系列笔记封装篇
- rabbitmq工具类带连接池
- Java|RabbitMQ-使用Java操作简单队列 simple queues