----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21937/ -----------------------------------------------------------
(Updated June 3, 2014, 6:15 p.m.) Review request for kafka. Summary (updated) ----------------- Patch for KAFKA-1316 Bugs: KAFKA-1316 https://issues.apache.org/jira/browse/KAFKA-1316 Repository: kafka Description (updated) ------- KAFKA-1316 Refactor a reusable NetworkClient interface out of Sender. Diffs (updated) ----- clients/src/main/java/org/apache/kafka/clients/ClientRequest.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/ClientResponse.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/ConnectionState.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/KafkaClient.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/NetworkClient.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/NodeConnectionState.java PRE-CREATION clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java d15562a968d9e4b08f26b8d30986881adfe29e31 clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java 9b1f5653548ba90defdae43940a5554066770b0a clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java 68b8827f3bdd64580e1b443fce5b8c63152dd94a clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java 428968cd38a7b12991f87868bf759926ff7e594e clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java PRE-CREATION clients/src/test/java/org/apache/kafka/clients/MockClient.java PRE-CREATION clients/src/test/java/org/apache/kafka/clients/NetworkClientTest.java PRE-CREATION clients/src/test/java/org/apache/kafka/clients/producer/RecordAccumulatorTest.java c4072ae90fb58101a67f83054fbe0b8349e71c2e clients/src/test/java/org/apache/kafka/clients/producer/SenderTest.java 3ef692ca3e9fb83868a9da6f30c0705bb3d0aed2 clients/src/test/java/org/apache/kafka/common/utils/MockTime.java cda8e644587aad9a8c9c96c222edc1ba27de1fb0 Diff: https://reviews.apache.org/r/21937/diff/ Testing ------- Thanks, Jay Kreps