flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8354) Flink Kafka connector ignores Kafka message headers
Date Wed, 24 Oct 2018 22:13:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16662923#comment-16662923

ASF GitHub Bot commented on FLINK-8354:

alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access
and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-432846236
   @yanghua, @aljoscha is anything else need to be done with this PR ?

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:

> Flink Kafka connector ignores Kafka message  headers 
> -----------------------------------------------------
>                 Key: FLINK-8354
>                 URL: https://issues.apache.org/jira/browse/FLINK-8354
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Kafka Connector
>         Environment: Kafka
> Flink 1.4.0
> flink-connector-kafka-0.11_2.11 
>            Reporter: Mohammad Abareghi
>            Assignee: Aegeaner
>            Priority: Major
>              Labels: pull-request-available
> Kafka has introduced notion of Header for messages in version  https://issues.apache.org/jira/browse/KAFKA-4208.
> But flink-connector-kafka-0.11_2.11 which supports kafka ignores headers when
consuming kafka messages. 
> It would be useful in some scenarios, such as distributed log tracing, to support message
headers to FlinkKafkaConsumer011 and FlinkKafkaProducer011. 

This message was sent by Atlassian JIRA

View raw message