mport org.dbsyncer.sdk.plugin.PluginContext;
import org.dbsyncer.sdk.spi.PluginService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyPlugin implements PluginService {

    private final Logger logger = LoggerFactory.getLogger(getClass());

    /**
     * 全量同步/增量同步
     *
     * @param convertContext
     */
    @Override
    public void convert(PluginContext pluginContext) {
        // TODO 消费或处理数据
        System.out.println("插件消费数据中...