I have some flink applications that read streams from Kafka, now the producer side code has introduced some additional information in Kafka headers while producing records. Now I need to change my consumer-side logic to process the records if the header contains a specific value, if the header value is different than the one I am looking I just need to move forward with the next steam.
I got some sample reference code <https://issues.apache.org/jira/browse/KAFKA-4208>but this logic needs to deserialize and verify the header. Is there any simple way to ignore the record before deserializing?
