diff --git a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanalConfigClient.java b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanalConfigClient.java index 2f509569..583091ed 100644 --- a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanalConfigClient.java +++ b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanalConfigClient.java @@ -16,6 +16,7 @@ import com.alibaba.otter.canal.common.AbstractCanalLifeCycle; import com.alibaba.otter.canal.common.CanalException; import com.alibaba.otter.canal.common.CanalLifeCycle; import com.alibaba.otter.canal.protocol.SecurityUtil; +import com.google.common.net.UrlEscapers; /** * 远程配置获取 @@ -84,7 +85,7 @@ public class PlainCanalConfigClient extends AbstractCanalLifeCycle implements Ca if (StringUtils.isEmpty(md5)) { md5 = ""; } - String url = configURL + "/api/v1/config/instance_polling/" + destination + "?md5=" + md5; + String url = configURL + "/api/v1/config/instance_polling/" + UrlEscapers.urlPathSegmentEscaper().escape(destination) + "?md5=" + md5; return queryConfig(url); }