[jira] [Created] (FLINK-11647) Use message headers in flink kafka connectors

[Shang Yuanchun (Jira)]

Sergey Starokozhev created FLINK-11647:
------------------------------------------

             Summary: 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


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)