[FLINK-3058] Add Kafka consumer for new 0.9.0.0 Kafka API

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.0
• Component/s: Connectors / Kafka
• Assignee: Robert Metzger
• Reporter: Robert Metzger
• Created: 22/Nov/15 17:16
• Updated: 20/Jan/16 21:53
• Resolved: 20/Jan/16 19:32

Description

The Apache Kafka project is about to release a new consumer API . They also changed their internal protocol so Kafka 0.9.0.0 users will need an updated consumer from Flink.

Also, I would like to let Flink be among the first stream processors supporting Kafka 0.9.0.0.

Issue Links

• is required by: FLINK-3239 Support for Kerberos enabled Kafka 0.9.0.0
• is required by: KAFKA-3109 Support for Kerberos enabled Kafka