-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/
-----------------------------------------------------------
(Updated Jan. 12, 2015, 12:57 a.m.)
Review request for kafka.
Summary (updated)
-----------------
Patch for KAFKA-1760
Bugs: KAFKA-1760
https://issues.apache.org/jira/browse/KAFKA-1760
Repository: kafka
Description (updated)
-------
New consumer.
Diffs (updated)
-----
build.gradle ba52288031e2abc70e35e9297a4423dd5025950b
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java
d32c319d8ee4c46dad309ea54b136ea9798e2fd7
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
8aece7e81a804b177a6f2c12e2dc6c89c1613262
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/ConnectionState.java
ab7e3220f9b76b92ef981d695299656f041ad5ed
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java
397695568d3fd8e835d8f923a89b3b00c96d0ead
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
6746275d0b2596cd6ff7ce464a3a8225ad75ef00
clients/src/main/java/org/apache/kafka/clients/RequestCompletionHandler.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java
1bce50185273dbdbc131fbc9c7f5f3e9c346517a
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
57c1807ccba9f264186f83e91f37c34b959c8060
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRebalanceCallback.java
e4cf7d1cfa01c2844b53213a7b539cdcbcbeaa3a
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
16af70a5de52cca786fdea147a6a639b7dc4a311
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
bdf4b26942d5a8c8a9503e05908e9a9eff6228a7
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
a5fedce9ff05ccfdb58ef083118d23bfa7a9bd4a
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java
8cab16c0a0bdb671fea1fc2fc2694247f66cc971
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
ea423ad15eebd262d20d5ec05d592cc115229177
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Heartbeat.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceCallback.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
8b3e565edd1ae04d8d34bd9f1a41e9fa8c880a75
clients/src/main/java/org/apache/kafka/clients/producer/internals/Metadata.java
1d30f9edd95337f86e632a09fc8f4126a67c238b
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
84a7a07269c51ccc22ebb4ff9797292d07ba778e
clients/src/main/java/org/apache/kafka/common/Cluster.java
d3299b944062d96852452de455902659ad8af757
clients/src/main/java/org/apache/kafka/common/PartitionInfo.java
b15aa2c3ef2d7c4b24618ff42fd4da324237a813
clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java
98cb79b701918eca3f6ca9823b6c7b7c97b3ecec
clients/src/main/java/org/apache/kafka/common/errors/ApiException.java
7c948b166a8ac07616809f260754116ae7764973
clients/src/main/java/org/apache/kafka/common/network/Selectable.java
b68bbf00ab8eba6c5867d346c91188142593ca6e
clients/src/main/java/org/apache/kafka/common/network/Selector.java
4dd2cdf773f7eb01a93d7f994383088960303dfc
clients/src/main/java/org/apache/kafka/common/protocol/Errors.java
3316b6a1098311b8603a4a5893bf57b75d2e43cb
clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java
121e880a941fcd3e6392859edba11a94236494cc
clients/src/main/java/org/apache/kafka/common/record/LogEntry.java
e4d688cbe0c61b74ea15fc8dd3b634f9e5ee9b83
clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java
040e5b91005edb8f015afdfa76fd94e0bf3cb4ca
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java
2fc471f64f4352eeb128bbd3941779780076fb8c
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetRequest.java
99364c1ca464f7b81be7d3da15b40ab66717a659
clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java
3ee5cbad55ce836fd04bb954dcf6ef2f9bc3288f
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java
6b7c269ad7679df57c6bd505516075add39b7534
clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java
3c001d33091c0f04ac3bf49a6731ab9e9f2bb0c4
clients/src/main/java/org/apache/kafka/common/utils/Utils.java
527dd0f9c47fce7310b7a37a9b95bf87f1b9c292
clients/src/test/java/org/apache/kafka/clients/MockClient.java
47b5d4ac1f2a5d162541cab658add9cc40b3aa4e
clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java
1a55242e9399fa4669630b55110d530f954e1279
clients/src/test/java/org/apache/kafka/clients/consumer/ConsumerExampleTest.java
29ad25e90606f065b409bc194ef9200189933aa6
clients/src/test/java/org/apache/kafka/clients/consumer/MockConsumerTest.java
PRE-CREATION
clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java
PRE-CREATION
clients/src/test/java/org/apache/kafka/clients/producer/BufferPoolTest.java
fe3c13f319d48b89a4f26b6d78c2c3e31cc50d7e
clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java
1e2ca03fafa36ebd29365c32e69773c8b98cef9b
clients/src/test/java/org/apache/kafka/clients/producer/PartitionerTest.java
1d077fd4c56bf28557a0ca1e15c82cc427f36e6c
clients/src/test/java/org/apache/kafka/clients/producer/SenderTest.java
ef2ca65cabe97b909f17b62027a1bb06827e88fe
clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java
3c442a27a7ba3eaa908becc802aab6242594df85
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java
5c5e3d40819e41cab7b52a0eeaee5f2e7317b7b3
clients/src/test/java/org/apache/kafka/common/utils/UtilsTest.java
a39fab532f73148316a56c0f8e9197f38ea66f79
clients/src/test/java/org/apache/kafka/test/MockSelector.java
d61de529173314c044261ad9662bec735d67e97f
core/src/main/scala/kafka/api/ConsumerMetadataRequest.scala
6d00ed090d76cd7925621a9c6db8fb00fb9d48f4
core/src/main/scala/kafka/api/ConsumerMetadataResponse.scala
84f60178f6ebae735c8aa3e79ed93fe21ac4aea7
core/src/main/scala/kafka/cluster/Partition.scala
b230e9a1fb1a3161f4c9d164e4890a16eceb2ad4
core/src/main/scala/kafka/controller/ControllerChannelManager.scala
eb492f00449744bc8d63f55b393e2a1659d38454
core/src/main/scala/kafka/log/LogConfig.scala
ca7a99e99f641b2694848b88bf4ae94657071d03
core/src/main/scala/kafka/server/KafkaApis.scala
c011a1b79bd6c4e832fe7d097daacb0d647d1cd4
core/src/main/scala/kafka/server/ReplicaManager.scala
e58fbb922e93b0c31dff04f187fcadb4ece986d7
core/src/main/scala/kafka/tools/ConsoleConsumer.scala
323fc8566d974acc4e5c7d7c2a065794f3b5df4a
core/src/main/scala/kafka/tools/ConsumerPerformance.scala
093c800ea7f8a9c972bb66e99ac4e4d431cf11cc
core/src/main/scala/kafka/tools/SimpleConsumerPerformance.scala
7602b8d705970a5dab49ed36d117346a960701ac
core/src/main/scala/kafka/utils/KafkaScheduler.scala
9a16343d2ff7192b741f0b23a6bdf58d8f2bbd3e
core/src/test/scala/integration/kafka/api/ConsumerTest.scala PRE-CREATION
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala
PRE-CREATION
core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala
cd16ced5465d098be7a60498326b2a98c248f343
core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala
3cf7c9bcd64492d05590067a8ad11d31096a8e5e
core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala
a5386a03b62956bc440b40783247c8cdf7432315
core/src/test/scala/unit/kafka/utils/MockScheduler.scala
d5896ed4d3b73aecb652436b5dfc80c2835af595
core/src/test/scala/unit/kafka/utils/SchedulerTest.scala
b364ac2d6d623f6e86805710ca68dc32d92558c1
core/src/test/scala/unit/kafka/utils/TestUtils.scala
c9e8ba257b77f46c5c9b62b451470348b6e58889
Diff: https://reviews.apache.org/r/27799/diff/
Testing
-------
Thanks,
Jay Kreps
