duxinglangzi
2022-04-23 6274208525b7e80c208f614915ef973d63834101
src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java
@@ -15,6 +15,13 @@
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 ");