this schema never considers an element to signal end-of-stream , so this method returns always false . concode_field_sep TypeInformation<Tuple2<K,V>> typeInfo concode_elem_sep long serialVersionUID concode_elem_sep DataInputDeserializer inputDeserializer concode_elem_sep DataOutputSerializer valueOutputSerializer concode_elem_sep TypeSerializer<V> valueSerializer concode_elem_sep DataOutputSerializer keyOutputSerializer concode_elem_sep TypeSerializer<K> keySerializer concode_field_sep String getTargetTopic concode_elem_sep byte[] serializeValue concode_elem_sep byte[] serializeKey concode_elem_sep Tuple2<K,V> deserialize concode_elem_sep TypeInformation<Tuple2<K,V>> getProducedType
boolean function ( Tuple2 < K , V > arg0 ) { return false ; }