@Override
        protected Header makeNext() {
            while (original.hasNext()) {
                Header header = original.next();
                if (!header.key().equals(key)) {
                    continue;
                }
                return header;
            }
            return this.allDone();
        }
Check that the value and its schema are compatible.

@param schemaAndValue the schema and value pair
@throws DataException if the schema is not compatible with the value
connect/api/src/main/java/org/apache/kafka/connect/header/ConnectHeaders.java