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);