flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ron Crocker <rcroc...@newrelic.com>
Subject Can I see the kafka header information in the Flink connector?
Date Thu, 22 Dec 2016 16:33:40 GMT
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
—
Ron Crocker
Principal Engineer & Architect
( ( •)) New Relic
rcrocker@newrelic.com
M: +1 630 363 8835


Mime
View raw message