[ https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14706975#comment-14706975 ]
ASF GitHub Bot commented on FLINK-2386: --------------------------------------- Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1039#issuecomment-133483983 Concerning the `FlinkKafkaConsumer081` and `FlinkKafkaConsumer082` - lets keep them exactly to fix bugs underneath the hood. I would actually move all this from the `flink-connector-kafka-083`to the other kafka connector project and replace the old `PersistentKafkaSource`. In a sepaate patch, we should we add some convenience constructors, where one can directly pass the list of brokers, rather than a properties object. > Implement Kafka connector using the new Kafka Consumer API > ---------------------------------------------------------- > > Key: FLINK-2386 > URL: https://issues.apache.org/jira/browse/FLINK-2386 > Project: Flink > Issue Type: Improvement > Components: Kafka Connector > Reporter: Robert Metzger > Assignee: Robert Metzger > > Once Kafka has released its new consumer API, we should provide a connector > for that version. > The release will probably be called 0.9 or 0.8.3. > The connector will be mostly compatible with Kafka 0.8.2.x, except for > committing offsets to the broker (the new connector expects a coordinator to > be available on Kafka). To work around that, we can provide a configuration > option to commit offsets to zookeeper (managed by flink code). > For 0.9/0.8.3 it will be fully compatible. > It will not be compatible with 0.8.1 because of mismatching Kafka messages. -- This message was sent by Atlassian JIRA (v6.3.4#6332)