[FLINK-3541] Clean up workaround in FlinkKafkaConsumer09

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Till Rohrmann
• Created: 29/Feb/16 15:14
• Updated: 13/Apr/16 08:47
• Resolved: 13/Apr/16 08:47

Description

In the current FlinkKafkaConsumer09 implementation, we repeatedly start a new KafkaConsumer if the method KafkaConsumer.partitionsFor returns a NPE. This is due to a bug with the Kafka version 0.9.0.0. See https://issues.apache.org/jira/browse/KAFKA-2880. The code can be found in the constructor of FlinkKafkaConsumer09.java:208.

However, the problem is marked as fixed for version 0.9.0.1, which we also use for the flink-connector-kafka. Therefore, we should be able to get rid of the workaround.