[
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)
