[jira] [Comment Edited] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11

["Piotr Nowojski (JIRA)" <ji...@apache.org>]

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

Piotr Nowojski edited comment on FLINK-9700 at 1/2/19 1:36 PM:
---------------------------------------------------------------

Yes, it would be good to add this note to our compatibility matrix/table. [~xleesf] or [~yanghua] will one of you add it?

Btw, it might be also a good idea to explicitly state in the documentation, that our 0.11 connector is also compatible with kafka versions >= 0.11 and not just with 0.11.


was (Author: pnowojski):
Yes, it would be good to add this note to our compatibility matrix/table. [~xleesf] or [~yanghua] will one of you add it?

> Document FlinkKafkaProducer behaviour for Kafka versions > 0.11
> ---------------------------------------------------------------
>
>                 Key: FLINK-9700
>                 URL: https://issues.apache.org/jira/browse/FLINK-9700
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector
>    Affects Versions: 1.5.0
>            Reporter: Ufuk Celebi
>            Assignee: leesf
>            Priority: Minor
>
> FlinkKafkaProducer for Kafka 0.11 uses reflection to work around API limitations of the Kafka client. Using reflection breaks with newer versions of the Kafka client (due to internal changes of the client).
> The documentation does not mention newer Kafka versions. We should add the following notes:
> - Only package Kafka connector with kafka.version property set to 0.11.*.*
> - Mention that it is possible to use the 0.11 connector with newer versions of Kafka as the protocol seems to be backwards compatible (double check that this is correct)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)