ASF GitHub Bot commented on FLINK-4035:

Github user cjstehno commented on the issue:

    Any thoughts on when this might make it into a release? We are having 
issues running Flink with Kafka 0.10 and would like to have an idea of whether 
we can/should wait for this or pull it and try building our own. Thanks.

> 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

Reply via email to