[ https://issues.apache.org/jira/browse/FLINK-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14715376#comment-14715376 ]
ASF GitHub Bot commented on FLINK-2386: --------------------------------------- Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1055#issuecomment-135146060 Manually merged this in 940a7c8a667875b8512b63e4a32453b1a2a58785 Finally in :-) The bot seems to not close this automatically (probably because it was not merged to master). Can you close this manually? > 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 > Fix For: 0.10, 0.9.1 > > > 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)