fix #904: 空记录时sleep 1s防止循环get数据过快
@@ -147,6 +147,12 @@ public class CanalKafkaStarter implements CanalServerStarter {
server.rollback(clientIdentity, batchId);
}
}); // 发送message到topic
+ } else {
+ try {
+ Thread.sleep(100);
+ } catch (InterruptedException e) {
+ // ignore
+ }
} catch (Exception e) {