flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka
Date Thu, 11 Aug 2016 09:29:20 GMT

     [ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Robert Metzger reassigned FLINK-4035:

    Assignee: Robert Metzger

> Bump Kafka producer in Kafka sink to Kafka
> ---------------------------------------------------
>                 Key: FLINK-4035
>                 URL: https://issues.apache.org/jira/browse/FLINK-4035
>             Project: Flink
>          Issue Type: Bug
>          Components: Kafka Connector
>    Affects Versions: 1.0.3
>            Reporter: Elias Levy
>            Assignee: Robert Metzger
>            Priority: Minor
> Kafka introduced protocol changes related to the producer.  Published messages
now include timestamps and compressed messages now include relative offsets.  As it is now,
brokers must decompress publisher compressed messages, assign offset to them, and recompress
them, which is wasteful and makes it less likely that compression will be used at all.

This message was sent by Atlassian JIRA

View raw message