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 b4e3a67f..aba22002 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,7 +73,7 @@ public class CanalServerWithEmbedded extends AbstractCanalLifeCycle implements C if (!isStart()) { super.start(); // 如果存在provider,则启动metrics service - if(metricsPort < 0) { + if(metricsPort > 0) { loadCanalMetrics(); metrics.setServerPort(metricsPort); metrics.initialize();