From 2d41bb99607ceb342be19cfc23aa4f275c9532cf Mon Sep 17 00:00:00 2001 From: mcy Date: Fri, 9 Nov 2018 18:19:51 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9mq=E9=85=8D=E7=BD=AE=E9=92=88?= =?UTF-8?q?=E5=AF=B9destination=E7=BA=A7=E5=88=AB=E9=87=8D=E5=90=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/alibaba/otter/canal/server/CanalMQStarter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/com/alibaba/otter/canal/server/CanalMQStarter.java b/server/src/main/java/com/alibaba/otter/canal/server/CanalMQStarter.java index d10fad77..ad4fc266 100644 --- a/server/src/main/java/com/alibaba/otter/canal/server/CanalMQStarter.java +++ b/server/src/main/java/com/alibaba/otter/canal/server/CanalMQStarter.java @@ -59,7 +59,7 @@ public class CanalMQStarter { canalServer = CanalServerWithEmbedded.instance(); // 对应每个instance启动一个worker线程 - executorService = Executors.newFixedThreadPool(canalServer.getCanalInstances().size()); + executorService = Executors.newCachedThreadPool(); logger.info("## start the MQ workers."); for (final CanalInstance canalInstance : canalServer.getCanalInstances().values()) { CanalMQRunnable canalMQRunnable = new CanalMQRunnable(canalInstance);