From 66408782b0eeebd3bc4a6aaa977c04822b94c027 Mon Sep 17 00:00:00 2001 From: hupeng Date: Fri, 16 Apr 2021 21:14:43 +0800 Subject: [PATCH] =?UTF-8?q?process()=E6=96=B9=E6=B3=95=E4=B8=AD=EF=BC=8C?= =?UTF-8?q?=E5=9C=A8retry=E5=BE=AA=E7=8E=AF=E4=B8=AD=E5=A4=84=E7=90=86?= =?UTF-8?q?=E6=88=90=E5=8A=9F=E5=BA=94=E8=AF=A5break=20(#3080)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit process()方法中，在retry循环中处理成功应该break --- .../otter/canal/adapter/launcher/loader/AdapterProcessor.java | 1 + 1 file changed, 1 insertion(+) diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java index 416d8c95..85601cd5 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java +++ b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java @@ -211,6 +211,7 @@ public class AdapterProcessor { canalDestination, System.currentTimeMillis() - begin); } + break; } catch (Exception e) { if (i != retry - 1) { canalMsgConsumer.rollback(); // 处理失败, 回滚数据