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)
