Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5269
@zentol
The contract is that if `KinesisDeserializationSchema.deserialize()`
returns `null`, that record will be skipped. I agree it makes sense to have a
add a warning log if this happens.---
