diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalLauncher.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalLauncher.java index aa9ac603..839daa99 100644 --- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalLauncher.java +++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalLauncher.java @@ -77,8 +77,9 @@ public class CanalLauncher { }); } - while (running) - ; + while (running) { + Thread.sleep(1000); + } if (managerDbConfigMonitor != null) { managerDbConfigMonitor.destroy(); diff --git a/deployer/src/main/resources/example/instance.properties b/deployer/src/main/resources/example/instance.properties index 30eb8b9e..03929772 100644 --- a/deployer/src/main/resources/example/instance.properties +++ b/deployer/src/main/resources/example/instance.properties @@ -45,8 +45,8 @@ canal.instance.filter.black.regex= # mq config canal.mq.topic=example -# dynamic topic route by table regex -#canal.mq.dynamicTopic=.*,mytest\\..*,mytest2.user +# dynamic topic route by schema or table regex +#canal.mq.dynamicTopic=.*,mytest,mytest\\..*,mytest2.user canal.mq.partition=0 # hash partition config #canal.mq.partitionsNum=3