diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java index 35c3f252..35b26460 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java @@ -73,6 +73,6 @@ public class MetaLogPositionManager extends AbstractLogPositionManager { @Override public void persistLogPosition(String destination, LogPosition logPosition) throws CanalParseException { // do nothing - logger.info("persist LogPosition:{}", destination, logPosition); + logger.info("destination [{}] persist LogPosition:{}", destination, logPosition); } } diff --git a/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java b/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java index 7532d244..a6515231 100644 --- a/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java +++ b/server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java @@ -184,7 +184,7 @@ public class CanalServerWithEmbedded extends AbstractCanalLifeCycle implements C } logger.info("subscribe successfully, {} with first position:{} ", clientIdentity, position); } else { - logger.info("subscribe successfully, use last cursor position:{} ", clientIdentity, position); + logger.info("subscribe successfully, {} use last cursor position:{} ", clientIdentity, position); } // 通知下订阅关系变化