private static void checkVersionCompatibility(short version) {
        // check for invalid versions
        if (version < CONNECT_PROTOCOL_V0)
            throw new SchemaException("Unsupported subscription version: " + version);

        // otherwise, assume versions can be parsed as V0
    }
The tasks included in this assignment.

@return the tasks
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java