flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "vinoyang (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (FLINK-9700) Document FlinkKafkaProducer behaviour for Kafka versions > 0.11
Date Mon, 02 Jul 2018 11:21:00 GMT

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

vinoyang reassigned FLINK-9700:
-------------------------------

    Assignee: vinoyang

> 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: vinoyang
>            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)

Mime
View raw message