@Override
    public void start() {
        splitAssigner.open();
        suspendBinlogReaderIfNeed();
        wakeupBinlogReaderIfNeed();
        this.context.callAsync(
                this::getRegisteredReader,
                this::syncWithReaders,
                CHECK_EVENT_INTERVAL,
                CHECK_EVENT_INTERVAL);
    }
A MySQL CDC source enumerator that enumerates receive the split request and assign the split to
source readers.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/enumerator/MySqlSourceEnumerator.java