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