-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34450/
-----------------------------------------------------------
Review request for kafka.
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
-----
core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala
6f05488bd3bf7ff81f07ff27b9b23f8a8d45ce58
core/src/main/scala/kafka/coordinator/CoordinatorMetadata.scala
88e82b66060f17223a023c743ff00ae53de4834b
core/src/main/scala/kafka/coordinator/Group.scala
048eeee4586acf74a8252591a318d0ba588b9ca9
core/src/main/scala/kafka/utils/ZkUtils.scala
2618dd39b925b979ad6e4c0abd5c6eaafb3db5d5
Diff: https://reviews.apache.org/r/34450/diff/
Testing
-------
Thanks,
Guozhang Wang