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
rcroc...@newrelic.com
M: +1 630 363 8835

Reply via email to