[FLINK-4722] Consumer group concept not working properly with FlinkKafkaConsumer09

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.1.2
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Sudhanshu Sekhar Lenka
• Created: 01/Oct/16 07:06
• Updated: 13/May/17 13:37
• Resolved: 13/May/17 13:37

Description

When Kafka one Topic has 3 partition and 3 FlinkKafkaConsumer09 connected to that same topic using "group.id" ,"myGroup" property . Still flink consumer get all data which are push to each 3 partition . While it work properly with normal java consumer. each consumer get specific data.