Hi devs Currently there are two deserialization methods in `DeserializationSchema` 1. `T deserialize(byte[] message)`, only deserialize one record from binary, if there is no record it should return null. 2. `void deserialize(byte[] message, Collector<T> out)`, supports deserializing none, one or multiple records gracefully, it can completely replace method `T deserialize(byte[] message)`.
The deserialization logic in the above two methods is basically coincident, we recommend users use the second method to deserialize data. To improve code maintainability, I'd like to mark the first function as `@Deprecated`, and remove it when it is no longer used in the future. I have created an issue[1] to track it, looking forward to your feedback, thanks [1] https://issues.apache.org/jira/browse/FLINK-31251 Best, Shammon