You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2019/02/22 11:24:00 UTC

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

    [ 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)