[FLINK-4822] Ensure that the Kafka 0.8 connector is compatible with kafka-consumer-groups.sh

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Robert Metzger
• Created: 13/Oct/16 10:26
• Updated: 18/Oct/19 12:09
• Resolved: 18/Oct/19 12:08

Description

The Kafka 0.8 connector is not properly creating all datastructures in Zookeeper for Kafka's kafka-consumer-groups.sh tool.

A user reported the issue here: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Kafka-connector08-not-updating-the-offsets-with-the-zookeeper-td9469.html#a9498

https://cwiki.apache.org/confluence/display/KAFKA/Kafka+data+structures+in+Zookeeper

Issue Links

• links to: GitHub Pull Request #5050
• links to: GitHub Pull Request #5050