From d8169cbf716e05e9a6cd803bbd9562ea07d23e1b Mon Sep 17 00:00:00 2001 From: "jianghang.loujh" Date: Fri, 28 Jul 2023 13:38:47 +0800 Subject: [PATCH] fixed issue #4813, support metric.port = -1 --- .../canal/server/embedded/CanalServerWithEmbedded.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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(); } }