Re: Can I see the kafka header information in the Flink connector?

Hi Ron, there is a KeyedDeserializationSchema for the Kafka connector, that exposes the source partition, offset and topic. Is that what you are looking for? On Thu, Dec 22, 2016 at 5:33 PM, Ron Crocker wrote: > Looking at the Kafka 0.8 connector API, my deserializer

Can I see the kafka header information in the Flink connector?

Looking at the Kafka 0.8 connector API, my deserializer definitely gets the message but none of the header information, and in particular, message metadata. Is there a straightforward way to do this (other than upgrading our Kafka cluster ;)). The connector code itself is a bit involved. Ron