增加动态参数配置

duxinglangzi

2022-06-24 4c9cf718ceb525f76da1fa4700a6e39bf964ebd8

 src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java

@@ -15,6 +15,14 @@


public class CanalConnectorFactory {



    /**

     * 创建 CanalConnector

     *

     * @param destination

     * @param endpointInstance

     * @return CanalConnector

     * @author wuqiong 2022-04-23 20:36

     */

    public static synchronized CanalConnector createConnector(

            String destination, CanalAutoConfigurationProperties.EndpointInstance endpointInstance) {

        Assert.isTrue(StringUtils.hasText(destination), "destination is null , please check ");