Re: Review Request 31850: Patch for KAFKA-1660

2015-05-12 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review83433 --- Ship it! Minor comments - I will address these on check-in.

Re: Review Request 31850: Patch for KAFKA-1660

2015-05-12 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated May 12, 2015, 9:29 p.m.) Review request for kafka. Bugs: KAFKA-1660

Re: Review Request 31850: Patch for KAFKA-1660

2015-05-04 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review82402 --- Ship it! Ship It! - Jay Kreps On April 30, 2015, 12:37 a.m.,

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-29 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 29, 2015, 11:58 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-29 Thread Jiangjie Qin
--- 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:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-22 Thread Jiangjie Qin
On April 20, 2015, 5:30 p.m., Jay Kreps wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 157 https://reviews.apache.org/r/31850/diff/9/?file=931821#file931821line157 Read locks are very expensive. I am pretty worried about

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-20 Thread Jiangjie Qin
On April 20, 2015, 5:30 p.m., Jay Kreps wrote: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, line 526 https://reviews.apache.org/r/31850/diff/9/?file=931818#file931818line526 I cleaned up this javadoc a little bit to try to simplify things. With

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 21, 2015, 12:38 a.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-20 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review80753 ---

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-16 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 16, 2015, 6:35 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-16 Thread Jiangjie Qin
On April 11, 2015, 8:02 p.m., Jay Kreps wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 155 https://reviews.apache.org/r/31850/diff/8/?file=923927#file923927line155 This scheme is clever but non-obvious, is there a simpler

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-11 Thread Jiangjie Qin
On April 11, 2015, 8:02 p.m., Jay Kreps wrote: Thanks for the review, Jay. Please see the reply below. On April 11, 2015, 8:02 p.m., Jay Kreps wrote: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, line 530

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 10, 2015, 10:09 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Jiangjie Qin
On April 10, 2015, 4:36 p.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 394 https://reviews.apache.org/r/31850/diff/7/?file=921104#file921104line394 I was trying to find a case where it wouldn't work, but I

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-10 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review79761 --- Ship it! - Guozhang Wang On April 10, 2015, 10:09 p.m., Jiangjie

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-08 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review79379 ---

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-08 Thread Jiangjie Qin
On April 8, 2015, 6:36 p.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 153 https://reviews.apache.org/r/31850/diff/6/?file=920399#file920399line153 Thanks for catching this issue, but can you explain it more

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-08 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 8, 2015, 9:01 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-07 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated April 8, 2015, 1:18 a.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-06 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review79063 --- Thanks for the patch.

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-06 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review79107 ---

Re: Review Request 31850: Patch for KAFKA-1660

2015-04-06 Thread Guozhang Wang
On April 7, 2015, 1:28 a.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java, line 362 https://reviews.apache.org/r/31850/diff/5/?file=908540#file908540line362 As you explained offline, the sender does not have access to

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-27 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated March 27, 2015, 11:35 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-25 Thread Jiangjie Qin
--- 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:

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-10 Thread Guozhang Wang
On March 9, 2015, 6:37 p.m., Guozhang Wang wrote: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, line 418 https://reviews.apache.org/r/31850/diff/2/?file=86#file86line418 This is not related to this ticket, but I think we can just throw e

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-10 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review75968 --- Ship it! LGTM. Just a minor comment on one of your replies. -

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-09 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review75731 ---

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-09 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated March 9, 2015, 7:56 p.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-09 Thread Jiangjie Qin
On March 9, 2015, 6:37 p.m., Guozhang Wang wrote: clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java, line 565 https://reviews.apache.org/r/31850/diff/2/?file=86#file86line565 Could metrics.close() be called simultaneously? I think so. It is

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-09 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/#review75742 ---

Review Request 31850: Patch for KAFKA-1660

2015-03-08 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- Review request for kafka. Bugs: KAFKA-1660

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-08 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated March 9, 2015, 4:07 a.m.) Review request for kafka. Bugs:

Re: Review Request 31850: Patch for KAFKA-1660

2015-03-08 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/31850/ --- (Updated March 9, 2015, 4:14 a.m.) Review request for kafka. Bugs: