格式化

duxinglangzi

2022-05-16 7cf9781edf66c75570af378a96b4011ff63ada92

 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 ");