[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933633#comment-14933633 ]
Dong Lin commented on KAFKA-2573: --------------------------------- [~ijuma] Thanks for referring me to this ticket. Yes, I think this is the same issue I described in KAFKA-2585. The solution I used in https://github.com/apache/kafka/pull/247 is different from that used by [~singhashish]. I think it would be better to fix it on the ConsoleConsumer.scala for this particular error -- because ConsoleConsumer shouldn't hang forever upon exception. I can see value for having a hardtimeout for any remove process in Ducktape test. But from my test experience I think there is already hard timeout as of Ducktape ac67e3f312d94c23ba06673c555fe557f1c9f39b, no? If we were to add a hard timeout, would it be better to enforce it as a general mechanism than having specific timeout for specific test, as is done in https://github.com/apache/kafka/pull/234? > Mirror maker system test hangs and eventually fails > --------------------------------------------------- > > Key: KAFKA-2573 > URL: https://issues.apache.org/jira/browse/KAFKA-2573 > Project: Kafka > Issue Type: Bug > Reporter: Ashish K Singh > Assignee: Ashish K Singh > > Due to changes made in KAFKA-2015, handling of {{--consumer.config}} has > changed, more details is specified on KAFKA-2467. This leads to the exception. > {code} > Exception in thread "main" java.lang.NoSuchMethodError: > java.util.concurrent.ConcurrentHashMap.keySet()Ljava/util/concurrent/ConcurrentHashMap$KeySetView; > at kafka.utils.Pool.keys(Pool.scala:77) > at > kafka.consumer.FetchRequestAndResponseStatsRegistry$.removeConsumerFetchRequestAndResponseStats(FetchRequestAndResponseStats.scala:69) > at > kafka.metrics.KafkaMetricsGroup$.removeAllConsumerMetrics(KafkaMetricsGroup.scala:189) > at > kafka.consumer.ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:200) > at kafka.consumer.OldConsumer.stop(BaseConsumer.scala:75) > at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:98) > at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:57) > at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:41) > at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)