睡眠一秒,防止ack未调用

独行的浪子

2022-04-25 3271cea1b986ee24c5bfaf2b15326554fb56090c

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