From issues-return-196616-archive-asf-public=cust-asf.ponee.io@flink.apache.org Mon Oct 22 21:33:29 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 8305F18064A for ; Mon, 22 Oct 2018 21:33:29 +0200 (CEST) Received: (qmail 93433 invoked by uid 500); 22 Oct 2018 19:33:23 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 93115 invoked by uid 99); 22 Oct 2018 19:33:23 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Oct 2018 19:33:23 +0000 From: GitBox To: issues@flink.apache.org Subject: [GitHub] eliaslevy commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector Message-ID: <154023680290.23326.5280443089113098341.gitbox@gitbox.apache.org> Date: Mon, 22 Oct 2018 19:33:22 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit eliaslevy commented on a change in pull request #6889: [FLINK-10599][Documentation] Provide documentation for the modern kafka connector URL: https://github.com/apache/flink/pull/6889#discussion_r227031828 ########## File path: docs/dev/connectors/kafka.md ########## @@ -80,6 +80,14 @@ For most users, the `FlinkKafkaConsumer08` (part of `flink-connector-kafka`) is 0.11.x Since 0.11.x Kafka does not support scala 2.10. This connector supports Kafka transactional messaging to provide exactly once semantic for the producer. + + flink-connector-kafka_2.11 + 1.7.0 + FlinkKafkaConsumer
+ FlinkKafkaProducer + 1.x,2.x + This is a modern kafka connector that does not bind to a fixed version of the Kafka client, it only tracks the latest version of the Kafka client. Review comment: You may want to rephrase this. change between releases to track the latest Kafka version. ```suggestion This Kafka connector attempts to track the latest version of the Kafka client. The version of the client it uses may change between Flink releases. Modern Kafka clients are backwards compatible with broker versions 0.10.0 or later. ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org With regards, Apache Git Services