@@ -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);
}
@@ -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);
// 通知下订阅关系变化