process()方法中,在retry循环中处理成功应该break
@@ -211,6 +211,7 @@ public class AdapterProcessor {
canalDestination,
System.currentTimeMillis() - begin);
}
+ break;
} catch (Exception e) {
if (i != retry - 1) {
canalMsgConsumer.rollback(); // 处理失败, 回滚数据