@Override
    protected boolean doPrepareToRead() {
        return true;
    }
kafka source, split kafka source job into multi readers
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/KafkaSource.java