diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java index 5e3101d7..691c41b2 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java +++ b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java @@ -9,6 +9,7 @@ import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.cloud.context.refresh.ContextRefresher; import org.springframework.core.env.Environment; import org.springframework.stereotype.Component; @@ -33,8 +34,10 @@ public class CanalAdapterService { private CanalAdapterLoader adapterLoader; @Resource - private AdapterCanalConfig adapterCanalConfig; + private ContextRefresher contextRefresher; + @Resource + private AdapterCanalConfig adapterCanalConfig; @Resource private Environment env; @@ -62,6 +65,7 @@ public class CanalAdapterService { configMonitor = new AdapterRemoteConfigMonitor(jdbcUrl, jdbcUsername, jdbcPassword); configMonitor.loadRemoteConfig(); configMonitor.loadRemoteAdapterConfigs(); + contextRefresher.refresh(); configMonitor.start(); } diff --git a/client-adapter/launcher/src/main/resources/application.yml b/client-adapter/launcher/src/main/resources/application.yml index 93480730..3baf2a17 100644 --- a/client-adapter/launcher/src/main/resources/application.yml +++ b/client-adapter/launcher/src/main/resources/application.yml @@ -12,10 +12,10 @@ spring: time-zone: GMT+8 default-property-inclusion: non_null -canal.manager.jdbc: - url: jdbc:mysql://127.0.0.1:3306/canal_manager?useUnicode=true&characterEncoding=UTF-8 - username: root - password: 121212 +#canal.manager.jdbc: +# url: jdbc:mysql://127.0.0.1:3306/canal_manager?useUnicode=true&characterEncoding=UTF-8 +# username: root +# password: 121212 canal:conf: canalServerHost: 127.0.0.1:11111