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.


---

Reply via email to