flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Sudhanshu Sekhar Lenka (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09
Date Mon, 03 Oct 2016 18:13:20 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15543036#comment-15543036
] 

Sudhanshu Sekhar Lenka commented on FLINK-4722:
-----------------------------------------------

according to your solution i have to iterate over all data that come to each consumer. which
is issue. we don't want to iterate over all data due to performance issue..

Thnx for your suggestion. By writing my own custom consumer  i am able to solve this issue.

> 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)

Mime
View raw message