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/container/AbstractCanalTransponderContainer.java |    1 +
 1 files changed, 1 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java b/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
index a72b664..2ded94c 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
@@ -47,6 +47,7 @@
     public void stop(Runnable callback) {
         callback.run();
         setRunning(false);
+        sleep(SLEEP_TIME_MILLI_SECONDS);
     }
 
     @Override

--
Gitblit v1.8.0