Simone Robutti commented on FLINK-4035:

The PR for kerberos integration for Kafka 0.9 has been merged recently. I don't 
know how does it work but maybe the work to make it compatible with this 
component should be done in this PR so we don't have a partial support for 
Kerberos on Kafka. 

> 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