[KAFKA-578] Leader finder thread in ConsumerFetcherManager needs to handle exceptions

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Fix Version/s: 0.8.0
• Component/s: core
• Labels: bugs newbie
• Assignee: Unassigned
• Reporter: Jun Rao
• Created: 18/Oct/12 16:24
• Updated: 23/Oct/12 22:15
• Resolved: 23/Oct/12 22:15

Description

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)