-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30083/
-----------------------------------------------------------
(Updated Jan. 20, 2015, 6:54 p.m.)
Review request for kafka.
Bugs: KAFKA-1839
https://issues.apache.org/jira/browse/KAFKA-1839
Repository: kafka
Description (updated)
-------
Added a beforeStartingFetchers hook to consumer rebalance listener.
Modified unit test.
Diffs
-----
core/src/main/scala/kafka/consumer/PartitionAssignor.scala
e6ff7683a0df4a7d221e949767e57c34703d5aad
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
191a8677444e53b043e9ad6e94c5a9191c32599e
core/src/main/scala/kafka/javaapi/consumer/ConsumerRebalanceListener.java
facf509841918bdcf92a271d29f6c825ff99345a
core/src/main/scala/kafka/tools/MirrorMaker.scala
5cbc8103e33a0a234d158c048e5314e841da6249
core/src/test/scala/unit/kafka/consumer/PartitionAssignorTest.scala
24954de66ccc5158696166b7e2aabad0f1b1f287
core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala
a17e8532c44aadf84b8da3a57bcc797a848b5020
Diff: https://reviews.apache.org/r/30083/diff/
Testing
-------
Thanks,
Jiangjie Qin
