[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Fix Version/s: 0.8.3 > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > Fix For: 0.8.3 > > Attachments: KAFKA-1333_2015-01-31_17:40:51.patch, > KAFKA-1333_2015-02-06_15:02:48.patch > > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Resolution: Fixed Status: Resolved (was: Patch Available) Resolve this ticket as a result of KAFKA-1334. > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > Attachments: KAFKA-1333_2015-01-31_17:40:51.patch, > KAFKA-1333_2015-02-06_15:02:48.patch > > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Attachment: KAFKA-1333_2015-02-06_15:02:48.patch > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > Attachments: KAFKA-1333_2015-01-31_17:40:51.patch, > KAFKA-1333_2015-02-06_15:02:48.patch > > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Status: Patch Available (was: Open) > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > Attachments: KAFKA-1333_2015-01-31_17:40:51.patch > > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Attachment: KAFKA-1333_2015-01-31_17:40:51.patch > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > Attachments: KAFKA-1333_2015-01-31_17:40:51.patch > > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1333: - Description: Scope of this JIRA is to just add a consumer co-ordinator module that do the following: 1) coordinator start-up, metadata initialization 2) simple join group handling (just updating metadata, no failure detection / rebalancing): this should be sufficient for consumers doing self offset / partition management. Offset manager will still run side-by-side with the coordinator in this JIRA, and we will merge it in KAFKA-1740. was:Scope of this JIRA is to just add a consumer co-ordinator module that doesn't do much initially. This will possibly require some refactor of the existing offset management stuff as the consumer co-ordinator and the offset group owner should be the same thing. This refactor and code review will be important as a lot of the consumer co-ordination code will go here. > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > > Scope of this JIRA is to just add a consumer co-ordinator module that do the > following: > 1) coordinator start-up, metadata initialization > 2) simple join group handling (just updating metadata, no failure detection / > rebalancing): this should be sufficient for consumers doing self offset / > partition management. > Offset manager will still run side-by-side with the coordinator in this JIRA, > and we will merge it in KAFKA-1740. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1333: - Assignee: Guozhang Wang > Add consumer co-ordinator module to the server > -- > > Key: KAFKA-1333 > URL: https://issues.apache.org/jira/browse/KAFKA-1333 > Project: Kafka > Issue Type: Sub-task > Components: consumer >Affects Versions: 0.9.0 >Reporter: Neha Narkhede >Assignee: Guozhang Wang > > Scope of this JIRA is to just add a consumer co-ordinator module that doesn't > do much initially. This will possibly require some refactor of the existing > offset management stuff as the consumer co-ordinator and the offset group > owner should be the same thing. This refactor and code review will be > important as a lot of the consumer co-ordination code will go here. -- This message was sent by Atlassian JIRA (v6.2#6252)