From 8ae8f526a6e6b10896864ef56216c58886c23889 Mon Sep 17 00:00:00 2001
From: machey <rewerma@163.com>
Date: Tue, 11 Sep 2018 22:47:53 +0800
Subject: [PATCH] =?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) {