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

Guozhang Wang commented on KAFKA-2017:
--------------------------------------

Rep [~becket_qin]:

1) Consumer also monitor the HB response and upon expiration mark the 
coordinator as dead, and tries to re-discover the new coordinator.

2) [~hachikuji] and I have discussed about similar proposals you mentioned 
above, i.e. coordinator ignoring the group check if the group id is unknown but 
knows this consumer group's previous coordinator is not itself. We realized the 
same problem and decided to go ahead with the persistency approach.

> Persist Coordinator State for Coordinator Failover
> --------------------------------------------------
>
>                 Key: KAFKA-2017
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2017
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: consumer
>    Affects Versions: 0.9.0.0
>            Reporter: Onur Karaman
>            Assignee: Guozhang Wang
>            Priority: Blocker
>             Fix For: 0.9.0.0
>
>         Attachments: KAFKA-2017.patch, KAFKA-2017_2015-05-20_09:13:39.patch, 
> KAFKA-2017_2015-05-21_19:02:47.patch
>
>
> When a coordinator fails, the group membership protocol tries to failover to 
> a new coordinator without forcing all the consumers rejoin their groups. This 
> is possible if the coordinator persists its state so that the state can be 
> transferred during coordinator failover. This state consists of most of the 
> information in GroupRegistry and ConsumerRegistry.



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

Reply via email to