Discard message on deserialization errors.

[John Smith]

Hi using Flink 1.8.0.

I am ingesting data from Kafka, unfortunately for the time being I have not
looked into using the schema registry.

So for now I would like to write a simple deserialization schema that
discards the data if deserialization fails.

The other option is to do in flat map with markers and split to dead letter
queue, but I'm not too concerned about that for now.

Is it ok to just return null if deserialization fails?

@Override
public MyObject deserialize(byte[] message) {
   try {
      return MyDecoder.decode(message));
   } catch    (IOException ex) {
      logger.warn("Failed to decode message.", ex);
      return null;
   }
}