@@ -77,8 +77,9 @@ public class CanalLauncher {
|
||||
});
|
||||
}
|
||||
|
||||
while (running)
|
||||
;
|
||||
while (running) {
|
||||
Thread.sleep(1000);
|
||||
}
|
||||
|
||||
if (managerDbConfigMonitor != null) {
|
||||
managerDbConfigMonitor.destroy();
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user