-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34450/
-----------------------------------------------------------
(Updated May 20, 2015, 4:13 p.m.)
Review request for kafka.
Summary (updated)
-----------------
Fix KAFKA-2017; rebased
Bugs: KAFKA-2017
https://issues.apache.org/jira/browse/KAFKA-2017
Repository: kafka
Description
-------
1. Upon receiving join-group, if the group metadata cannot be found in the
local cache try to read it from ZK; 2. Upon completing rebalance, update the ZK
with new group registry or delete the registry if the group becomes empty
Diffs (updated)
-----
core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala
af06ad45cdc46ac3bc27898ebc1a5bd5b1c7b19e
core/src/main/scala/kafka/coordinator/ConsumerGroupMetadata.scala
47bdfa7cc86fd4e841e2b1d6bfd40f1508e643bd
core/src/main/scala/kafka/coordinator/CoordinatorMetadata.scala
c39e6de34ee531c6dfa9107b830752bd7f8fbe59
core/src/main/scala/kafka/utils/ZkUtils.scala
2618dd39b925b979ad6e4c0abd5c6eaafb3db5d5
Diff: https://reviews.apache.org/r/34450/diff/
Testing
-------
Thanks,
Guozhang Wang
