canal-spring
canal-spring copied to clipboard
运行时间超过几个小时报错
当运行时间超过几个小时就会报这个错误
求作者解答 万分感谢
根据你的截图来看,很久没有收到消息,猜测可能是长时间未通讯断开连接,这个我也没遇到过。我一直用的kafka模式,要不你改下 canal 服务端的 canal.instance.network.soTimeout
配置试试看
问题原因可能由于是 ThreadPoolAutoConfiguration
里线程池配置:
new ThreadPoolExecutor(20, 100, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024), factory, new ThreadPoolExecutor.AbortPolicy());
一个事物里涉及到太多数据变化后,提交事物后将线程池占满了导致拒绝引起的