diff --git a/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java b/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java index 9d8d563e..b4e3a67f 100644 --- a/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java +++ b/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java @@ -73,11 +73,12 @@ public class CanalServerWithEmbedded extends AbstractCanalLifeCycle implements C if (!isStart()) { super.start(); // 如果存在provider,则启动metrics service - loadCanalMetrics(); - metrics.setServerPort(metricsPort); - metrics.initialize(); + if(metricsPort < 0) { + loadCanalMetrics(); + metrics.setServerPort(metricsPort); + metrics.initialize(); + } canalInstances = MigrateMap.makeComputingMap(destination -> canalInstanceGenerator.generate(destination)); - // lastRollbackPostions = new MapMaker().makeMap(); } }