@Override
    public List<Reader> split(JobProfile conf) {
        super.init(conf);
        BinlogReader binlogReader = new BinlogReader();
        binlogReader.setReadSource(conf.getInstanceId());
        List<Reader> readerList = new ArrayList<>();
        readerList.add(binlogReader);
        sourceMetric.sourceSuccessCount.incrementAndGet();
        return readerList;
    }
binlog source, split binlog source job into multi readers
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/BinlogSource.java