flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Re: Can I see the kafka header information in the Flink connector?
Date Sat, 24 Dec 2016 08:37:48 GMT
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 <rcrocker@newrelic.com> wrote:

> 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 <+1%20630-363-8835>
>
>

Mime
View raw message