You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Swapnil Ghike (JIRA)" <ji...@apache.org> on 2012/10/23 22:35:12 UTC

[jira] [Assigned] (KAFKA-578) Leader finder thread in ConsumerFetcherManager needs to handle exceptions

     [ https://issues.apache.org/jira/browse/KAFKA-578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Swapnil Ghike reassigned KAFKA-578:
-----------------------------------

    Assignee: Swapnil Ghike
    
> Leader finder thread in ConsumerFetcherManager needs to handle exceptions
> -------------------------------------------------------------------------
>
>                 Key: KAFKA-578
>                 URL: https://issues.apache.org/jira/browse/KAFKA-578
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.8
>            Reporter: Jun Rao
>            Assignee: Swapnil Ghike
>            Priority: Blocker
>              Labels: bugs, newbie
>   Original Estimate: 24h
>  Remaining Estimate: 24h
>
> Saw the leader finder thread due to the following exception. We need to add a try/catch clause to handle the exceptions.
> [2012-10-11 17:17:14,192] ERROR [mm_regtest_grp_jrao-ld-1350000983383-47e0e557-leader-finder-thread], Error due to  (kafka.consumer.ConsumerFetcherManager$$anon$1)
> kafka.common.KafkaException: fetching topic metadata for topics [Set(test_1)] from broker [ArrayBuffer()] failed
>         at kafka.utils.Utils$.getTopicMetadata(Utils.scala:704)
>         at kafka.consumer.ConsumerFetcherManager$$anon$1.doWork(ConsumerFetcherManager.scala:55)
>         at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:50)

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira