From 3ed89877796ab113504165578b7555870b589884 Mon Sep 17 00:00:00 2001 From: duhengforever Date: Sun, 30 Sep 2018 09:49:13 +0800 Subject: [PATCH] Remove useless log print --- .../otter/canal/client/rocketmq/RocketMQCanalConnector.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java index f24955c7..8031e792 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java @@ -73,10 +73,8 @@ public class RocketMQCanalConnector implements CanalConnector { public ConsumeOrderlyStatus consumeMessage(List messageExts, ConsumeOrderlyContext context) { context.setAutoCommit(true); - logger.info("xxxx"); boolean isSuccess = process(messageExts); if (isSuccess) { - logger.info("Dispatch success!"); return ConsumeOrderlyStatus.SUCCESS; } else { return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;