-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31850/
-----------------------------------------------------------
(Updated March 25, 2015, 5:55 p.m.)
Review request for kafka.
Bugs: KAFKA-1660
https://issues.apache.org/jira/browse/KAFKA-1660
Repository: kafka
Description (updated)
-------
A minor fix.
Incorporated Guozhang's comments.
Modify according to the latest conclusion.
Diffs (updated)
-----
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
ab263423ff1d33170effb71acdef3fc501fa072a
clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java
6913090af03a455452b0b5c3df78f266126b3854
clients/src/main/java/org/apache/kafka/clients/producer/Producer.java
5b3e75ed83a940bc922f9eca10d4008d67aa37c9
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
88b4e4fbf3bf6fb6d2f90551a792b95d4cd51c40
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
70954cadb5c7e9a4c326afcf9d9a07db230e7db2
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java
fee322fa0dd9704374db4a6964246a7d2918d3e4
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java
c2fdc23239bd2196cd912c3d121b591f21393eab
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
e379ac89c9a2fbfe750d6b0dec693b7eabb76204
core/src/test/scala/integration/kafka/api/ProducerSendTest.scala
3df450784592b894008e7507b2737f9bb07f7bd2
Diff: https://reviews.apache.org/r/31850/diff/
Testing
-------
Unit tests passed.
Thanks,
Jiangjie Qin
