package com.dtstack.jlogstash.inputs;


import com.alibaba.otter.canal.parse.exception.CanalParseException;
import com.alibaba.otter.canal.parse.index.AbstractLogPositionManager;
import com.alibaba.otter.canal.protocol.position.LogPosition;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class BinlogPositionManager extends AbstractLogPositionManager {

    private static final Logger logger = LoggerFactory.getLogger(BinlogPositionManager.class);

    private final Binlog binlog;

    public BinlogPositionManager(Binlog binlog) {
        this.binlog = binlog;
    }

    @Override
    public LogPosition getLatestIndexBy(String destination) {
        return null;
    }

    @Override
    public void persistLogPosition(String destination, LogPosition logPosition) throws CanalParseException {
        logger.info("persistLogPosition: " + logPosition.toString());
        binlog.updateLastPos(logPosition.getPostion());
    }

}

@@ -821,16 +821,19 @@
     
+if(
 logger.i
 nfo(
@@ -832,11 +832,50 @@
 er.i
-nfo
+sDebugEnabled())%7B%0A            logger.debug
 (%22pe
@@ -917,24 +917,34 @@
 oString());%0A
+        %7D%0A
         binl

remove info