-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34789/
-----------------------------------------------------------
(Updated June 1, 2015, 11:04 p.m.)
Review request for kafka.
Bugs: KAFKA-2168
https://issues.apache.org/jira/browse/KAFKA-2168
Repository: kafka
Description (updated)
-------
KAFKA-2168; move blocking calls into KafkaConsumer to enable async wakeup()
Diffs (updated)
-----
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java
8f587bc0705b65b3ef37c86e0c25bb43ab8803de
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerWakeupException.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
d301be4709f7b112e1f3a39f3c04cfa65f00fa60
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java
f50da825756938c193d7f07bee953e000e2627d9
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Coordinator.java
b2764df11afa7a99fce46d1ff48960d889032d14
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
ef9dd5238fbc771496029866ece1d85db6d7b7a5
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetchResult.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
cee75410127dd1b86c1156563003216d93a086b3
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java
677edd385f35d4262342b567262c0b874876d25b
clients/src/test/java/org/apache/kafka/clients/consumer/internals/CoordinatorTest.java
b06c4a73e2b4e9472cd772c8bc32bf4a29f431bb
clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
419541011d652becf0cda7a5e62ce813cddb1732
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
e000cf8e10ebfacd6c9ee68d7b88ff8c157f73c6
Diff: https://reviews.apache.org/r/34789/diff/
Testing
-------
Thanks,
Jason Gustafson
