From 3271cea1b986ee24c5bfaf2b15326554fb56090c Mon Sep 17 00:00:00 2001 From: 独行的浪子 <871364441@qq.com> Date: 星期一, 25 四月 2022 16:15:32 +0800 Subject: [PATCH] 睡眠一秒,防止ack未调用 --- src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java b/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java index 68f63da..d1ed7cd 100644 --- a/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java +++ b/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 "); -- Gitblit v1.8.0