Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5958#discussion_r186606104 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/serialization/DeserializationSchema.java --- @@ -42,14 +42,22 @@ @Public public interface DeserializationSchema<T> extends Serializable, ResultTypeQueryable<T> { + /** + * @deprecated Use {@link #deserialize(ConsumerRecordMetaInfo)} . + */ + @Deprecated + T deserialize(byte[] message) throws IOException; + /** * Deserializes the byte message. * - * @param message The message, as a byte array. + * @param consumerRecordMetaInfossage The message, as a {@link ConsumerRecordMetaInfo}. * * @return The deserialized message as an object (null if the message cannot be deserialized). */ - T deserialize(byte[] message) throws IOException; + default T deserialize(ConsumerRecordMetaInfo consumerRecordMetaInfossage) throws IOException { --- End diff -- Makes sense. Alright, lets leave this as is then.
---