-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31850/
-----------------------------------------------------------
(Updated April 30, 2015, 12:37 a.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.
Patch for the finally passed KIP-15git status
Addressed Joel and Guozhang's comments.
rebased on trunk
Rebase on trunk
Addressed Joel's comments.
Addressed Joel's comments
Addressed Jay's comments
Change java doc as Jay suggested.
Go back to the AtomicInteger approach for less dependency.
Rebased on trunk
Add some missing code from rebase.
Diffs (updated)
-----
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
42b12928781463b56fc4a45d96bb4da2745b6d95
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
49a98838767615dd952da20825f6985698137710
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
b2db91ca14bbd17fef5ce85839679144fff3f689
clients/src/main/java/org/apache/kafka/common/errors/InterruptException.java
fee322fa0dd9704374db4a6964246a7d2918d3e4
clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java
c44054038066f0d0829d05f082b2ee42b34cded7
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java
baa48e7c1b7ac5da8f3aca29f653c3fff88f8009
core/src/test/scala/integration/kafka/api/ProducerSendTest.scala
9811a2b2b1e9bf1beb301138f7626e12d275a8db
Diff: https://reviews.apache.org/r/31850/diff/
Testing
-------
Unit tests passed.
Thanks,
Jiangjie Qin
