From 8ae8f526a6e6b10896864ef56216c58886c23889 Mon Sep 17 00:00:00 2001 From: machey Date: Tue, 11 Sep 2018 22:47:53 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix=20#904:=20=E7=A9=BA=E8=AE=B0=E5=BD=95?= =?UTF-8?q?=E6=97=B6sleep=201s=E9=98=B2=E6=AD=A2=E5=BE=AA=E7=8E=AFget?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=BF=87=E5=BF=AB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/alibaba/otter/canal/kafka/CanalKafkaStarter.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java index 717a4525..0632417c 100644 --- a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java +++ b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java @@ -147,6 +147,12 @@ public class CanalKafkaStarter implements CanalServerStarter { server.rollback(clientIdentity, batchId); } }); // 发送message到topic + } else { + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + // ignore + } } } catch (Exception e) { From a6798c61df15741bc5ae4d46e93718db445bbcc1 Mon Sep 17 00:00:00 2001 From: mcy Date: Wed, 12 Sep 2018 09:03:43 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E7=A9=BA=E6=95=B0=E6=8D=AEsleep=20100ms?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java index 0632417c..5b73bf3b 100644 --- a/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java +++ b/server/src/main/java/com/alibaba/otter/canal/kafka/CanalKafkaStarter.java @@ -149,7 +149,7 @@ public class CanalKafkaStarter implements CanalServerStarter { }); // 发送message到topic } else { try { - Thread.sleep(1000); + Thread.sleep(100); } catch (InterruptedException e) { // ignore }