Hey, Sorry for such a delay, but I have missed this message. Basically, technically you could have Kafka broker installed in version say 1.0.0 and using FlinkKafkaConsumer08. This could technically create issues. I'm not sure if You can automate the process of skipping corrupted messages, as You would have to write the consumer that will allow skipping messages that are corrupted. This maybe a good idea to think about for Flink though.
On the other hand, if You have many messages that are corrupted, this may mean that the problem lies elsewhere within You pipeline (kafka producers before Flink).
