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