kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vahid Hashemian (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-3664) When subscription set changes on new consumer, the partitions may be removed without offset being committed.
Date Fri, 09 Sep 2016 05:10:20 GMT

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

Vahid Hashemian commented on KAFKA-3664:
----------------------------------------

Fix was provided under [KIP-70|https://cwiki.apache.org/confluence/display/KAFKA/KIP-70%3A+Revise+Partition+Assignment+Semantics+on+New+Consumer's+Subscription+Change].

> When subscription set changes on new consumer, the partitions may be removed without
offset being committed.
> ------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-3664
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3664
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jiangjie Qin
>            Assignee: Vahid Hashemian
>
> When users are using group management, if they call consumer.subscribe() to change the
subscription, the removed subscriptions will be immediately removed and their offset will
not be commit. Also the revoked partitions passed to the ConsumerRebalanceListener.onPartitionsRevoked()
will not include those partitions. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message