You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ismael Juma (JIRA)" <ji...@apache.org> on 2015/09/24 16:57:04 UTC
[jira] [Comment Edited] (KAFKA-2573) Mirror maker system test hangs
and eventually fails
[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906454#comment-14906454 ]
Ismael Juma edited comment on KAFKA-2573 at 9/24/15 2:56 PM:
-------------------------------------------------------------
I think the test should fail fast indeed. The system tests are meant to test the system working together and if one part is failing (for whatever reason), we should know about it. This is one of the main benefits of system tests when compared to the JUnit tests we have (which isolate things more).
was (Author: ijuma):
I think the test should fail fast indeed. The system tests are meant to test the system working together and if one part is failing (for whatever reason), we should know about it. This is one of the main benefits of system tests when compared to the JUnit tests we have.
> 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)