----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/20050/#review39836 -----------------------------------------------------------
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java <https://reviews.apache.org/r/20050/#comment72523> I agree, it is better to register this in Selector. This would not solve the unit tests though since there are Sender unit tests that will be broken then.. - Guozhang Wang On April 4, 2014, 9:33 p.m., Guozhang Wang wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/20050/ > ----------------------------------------------------------- > > (Updated April 4, 2014, 9:33 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-1359 > https://issues.apache.org/jira/browse/KAFKA-1359 > > > Repository: kafka > > > Description > ------- > > KAFKA-1359.v1 > > > Diffs > ----- > > > clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java > 855ae84f14aa91653b3fa855c2af40560323f42a > clients/src/main/java/org/apache/kafka/common/network/Selector.java > 558f8b47638b354f9c1a30be5d45dc7b61131bea > > Diff: https://reviews.apache.org/r/20050/diff/ > > > Testing > ------- > > > Thanks, > > Guozhang Wang > >
