怪异的bug 2021-09-22 13:58 采纳率: 0%
浏览 76

rocket MQ生产者,有时候发送失败,大部分发送成功,求解

异常如下:

No route info of this topic, flight_data_sync_iaoc
See http://docs.aliyun.com/cn#/pub/ons/faq/exceptions&topic_not_exist for further details.
18:27:29.683 [NettyClientSelector_1] WARN  c.a.r.s.i.n.c.ChannelInitializer - [warn,151] - Failed to initialize a channel. Closing: [id: 0x52e8fb3e]
java.util.concurrent.RejectedExecutionException: event executor terminated
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:715)
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:300)
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:691)
    at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.AbstractEventExecutor.submit(AbstractEventExecutor.java:91)
    at com.alibaba.rocketmq.shade.io.netty.channel.DefaultChannelPipeline.addLast(DefaultChannelPipeline.java:210)
    at com.alibaba.rocketmq.shade.io.netty.channel.DefaultChannelPipeline.addLast(DefaultChannelPipeline.java:390)
    at com.alibaba.rocketmq.remoting.netty.NettyRemotingClient$4.initChannel(NettyRemotingClient.java:150)
    at com.alibaba.rocketmq.remoting.netty.NettyRemotingClient$4.initChannel(NettyRemotingClient.java:147)
    at com.alibaba.rocketmq.shade.io.netty.channel.ChannelInitializer.channelRegistered(ChannelInitializer.java:68)
    at com.alibaba.rocketmq.shade.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRegistered(AbstractChannelHandlerContext.java:118)
    at com.alibaba.rocketmq.shade.io.netty.channel.AbstractChannelHandlerContext.fireChannelRegistered(AbstractChannelHandlerContext.java:104)
    at com.alibaba.rocketmq.shade.io.netty.channel.DefaultChannelPipeline.fireChannelRegistered(DefaultChannelPipeline.java:846)
    at com.alibaba.rocketmq.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:453)
    at com.alibaba.rocketmq.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:370)
    at com.alibaba.rocketmq.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:420)
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:358)
    at com.alibaba.rocketmq.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:374)
    at com.alibaba.rocketmq.shade.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
    at java.lang.Thread.run(Thread.java:745)

  • 写回答

1条回答 默认 最新

  • 普通网友 2021-09-22 14:11
    关注

    1、你是不是限制了主题数量?
    2、你是不是开启了自动创建主题?
    3、你网络是不是有限制?

    评论

报告相同问题?

问题事件

  • 创建了问题 9月22日

悬赏问题

  • ¥15 c语言怎么用printf(“\b \b”)与getch()实现黑框里写入与删除?
  • ¥20 怎么用dlib库的算法识别小麦病虫害
  • ¥15 华为ensp模拟器中S5700交换机在配置过程中老是反复重启
  • ¥15 java写代码遇到问题,求帮助
  • ¥15 uniapp uview http 如何实现统一的请求异常信息提示?
  • ¥15 有了解d3和topogram.js库的吗?有偿请教
  • ¥100 任意维数的K均值聚类
  • ¥15 stamps做sbas-insar,时序沉降图怎么画
  • ¥15 买了个传感器,根据商家发的代码和步骤使用但是代码报错了不会改,有没有人可以看看
  • ¥15 关于#Java#的问题,如何解决?