Sudhanshu Sekhar Lenka created FLINK-4722:
---------------------------------------------
Summary: Consumer group concept not working properly with
FlinkKafkaConsumer09
Key: FLINK-4722
URL: https://issues.apache.org/jira/browse/FLINK-4722
Project: Flink
Issue Type: Bug
Components: Kafka Connector
Affects Versions: 1.1.2
Reporter: Sudhanshu Sekhar Lenka
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
