[
https://issues.apache.org/jira/browse/FLINK-11647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16775039#comment-16775039
]
Aljoscha Krettek commented on FLINK-11647:
------------------------------------------
This is now implemented, see FLINK-8354.
> Use message headers in flink kafka connectors
> ---------------------------------------------
>
> Key: FLINK-11647
> URL: https://issues.apache.org/jira/browse/FLINK-11647
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Sergey Starokozhev
> Priority: Major
>
> It is required to add the ability to use kafka message headers in class
> FlinkKafkaConsumer. This will make it possible, for example, to use different
> avro message schemes. Now we can only use key, value, topic, partiotion and
> offset but not headers: [Kafka09Fetcher.java -142]:
> _final T value = deserializer.deserialize(_
> _record.key(), record.value(),_
> _record.topic(), record.partition(), record.offset());_
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
