-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/
-----------------------------------------------------------
Review request for kafka.
Bugs: KAFKA-1760
https://issues.apache.org/jira/browse/KAFKA-1760
Repository: kafka
Description
-------
KAFKA-1330 Draft version of the new consumer.
Diffs
-----
clients/src/main/java/org/apache/kafka/clients/KafkaClient.java
29658d4a15f112dc0af5ce517eaab93e6f00134b
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
eea270abb16f40c9f3b47c4ea96be412fb4fdc8b
clients/src/main/java/org/apache/kafka/clients/consumer/CommitType.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java
227f5646ee708af1b861c15237eda2140cfd4900
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java
46efc0c8483acacf42b2984ac3f3b9e0a4566187
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java
436d8a479166eda29f2672b50fc99f288bbe3fa9
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
2ecfc8aaea90a7353bd0dabc4c0ebcc6fd9535ec
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
fe93afa24fc20b03830f1d190a276041d15bd3b9
clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java
c3aad3b4d6b677f759583f309061193f2f109250
clients/src/main/java/org/apache/kafka/clients/consumer/NoOffsetForPartition.java
PRE-CREATION
clients/src/main/java/org/apache/kafka/clients/consumer/OffsetMetadata.java
ea423ad15eebd262d20d5ec05d592cc115229177
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
8ebe7ed82c9384b71ce0cc3ddbef2c2325363ab9
clients/src/main/java/org/apache/kafka/common/Cluster.java
d3299b944062d96852452de455902659ad8af757
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/types/Struct.java
121e880a941fcd3e6392859edba11a94236494cc
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/utils/Utils.java
527dd0f9c47fce7310b7a37a9b95bf87f1b9c292
clients/src/test/java/org/apache/kafka/clients/MockClient.java
aae8d4a1e98279470587d397cc779a9baf6fee6c
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/producer/PartitionerTest.java
f06e28ce21e80c1265258ad3ac7900b99e61493d
clients/src/test/java/org/apache/kafka/common/network/SelectorTest.java
5c5e3d40819e41cab7b52a0eeaee5f2e7317b7b3
clients/src/test/java/org/apache/kafka/test/MockSelector.java
d61de529173314c044261ad9662bec735d67e97f
core/src/main/scala/kafka/server/KafkaApis.scala
968b0c4f809ea9f9c3f322aef9db105f9d2e0e23
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/integration/KafkaServerTestHarness.scala
3cf7c9bcd64492d05590067a8ad11d31096a8e5e
core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala
a5386a03b62956bc440b40783247c8cdf7432315
core/src/test/scala/unit/kafka/utils/TestUtils.scala
dd3640f47b26a4ff1515c2dc7e964550ac35b7b2
Diff: https://reviews.apache.org/r/27799/diff/
Testing
-------
Thanks,
Jay Kreps
