-----------------------------------------------------------
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

Reply via email to