> On June 3, 2015, 6:53 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/consumer/SimpleConsumer.scala, line 61 > > <https://reviews.apache.org/r/34965/diff/1/?file=976904#file976904line61> > > > > Why not simply modify the close method to disconnect outside the > > synchronized block? Not that I feel very strongly, I'm curious.
Sure. I will think about this after finishing other works. > On June 3, 2015, 6:53 p.m., Aditya Auradkar wrote: > > core/src/main/scala/kafka/consumer/SimpleConsumer.scala, line 63 > > <https://reviews.apache.org/r/34965/diff/1/?file=976904#file976904line63> > > > > I think this needs to be volatile or AtomicBoolean You are right. Fixed. Thanks. - Dong ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34965/#review86460 ----------------------------------------------------------- On June 3, 2015, 10:30 p.m., Dong Lin wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/34965/ > ----------------------------------------------------------- > > (Updated June 3, 2015, 10:30 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-2241 > https://issues.apache.org/jira/browse/KAFKA-2241 > > > Repository: kafka > > > Description > ------- > > KAFKA-2241; AbstractFetcherThread.shutdown() should not block on > ReadableByteChannel.read(buffer) > > > Diffs > ----- > > core/src/main/scala/kafka/consumer/SimpleConsumer.scala > 31a2639477bf66f9a05d2b9b07794572d7ec393b > core/src/main/scala/kafka/server/AbstractFetcherThread.scala > 83fc47417dd7fe4edf030217fa7fd69d99b170b0 > > Diff: https://reviews.apache.org/r/34965/diff/ > > > Testing > ------- > > > Thanks, > > Dong Lin > >
