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
    }
Given a byte buffer that contains an assignment as defined by this protocol, return the
deserialized form of the assignment.

@param buffer the buffer containing a serialized assignment
@return the deserialized assignment
@throws SchemaException on incompatible Connect protocol version
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeConnectProtocol.java