> On July 28, 2015, 8:16 a.m., Ismael Juma wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java, > > line 86 > > <https://reviews.apache.org/r/36871/diff/4/?file=1023358#file1023358line86> > > > > A minor optimisation is to use `ArrayList` here to avoid rehashing the > > items in the list.
Fair point, addressed. - Ashish ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36871/#review93256 ----------------------------------------------------------- On July 28, 2015, 4:17 p.m., Ashish Singh wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/36871/ > ----------------------------------------------------------- > > (Updated July 28, 2015, 4:17 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-2381 > https://issues.apache.org/jira/browse/KAFKA-2381 > > > Repository: kafka > > > Description > ------- > > Address review comment > > > Move closing of consumer to finally > > > Add a more specific unit test > > > KAFKA-2381: Possible ConcurrentModificationException while unsubscribing from > a topic in new consumer > > > Diffs > ----- > > > clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java > 4d9a425201115a66b457b58d670992b279091f5a > > clients/src/test/java/org/apache/kafka/clients/consumer/internals/SubscriptionStateTest.java > 319751c374ccdc7e7d7d74bcd01bc279b1bdb26e > core/src/test/scala/integration/kafka/api/ConsumerTest.scala > 3eb5f95731a3f06f662b334ab2b3d0ad7fa9e1ca > > Diff: https://reviews.apache.org/r/36871/diff/ > > > Testing > ------- > > > Thanks, > > Ashish Singh > >
