[KAFKA-212] IllegalThreadStateException in topic watcher for Kafka mirroring

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.7.1
• Assignee: Neha Narkhede
• Reporter: Neha Narkhede
• Created: 23/Nov/11 19:43
• Updated: 01/Dec/11 01:04
• Resolved: 01/Dec/11 01:04

Description

If the kafka mirroring embedded consumer receives a new topic watcher notification, it runs into the following exception

[2011-11-23 02:49:15,612] FATAL java.lang.IllegalThreadStateException (kafka.consumer.ZookeeperTopicEventWatcher)
[2011-11-23 02:49:15,612] FATAL java.lang.IllegalThreadStateException
at java.lang.Thread.start(Thread.java:595)
at kafka.server.EmbeddedConsumer$$anonfun$startNewConsumerThreads$3.apply(KafkaServerStartable.scala:142)
at kafka.server.EmbeddedConsumer$$anonfun$startNewConsumerThreads$3.apply(KafkaServerStartable.scala:142)
at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
at scala.collection.immutable.List.foreach(List.scala:45)
at kafka.server.EmbeddedConsumer.startNewConsumerThreads(KafkaServerStartable.scala:142)
at kafka.server.EmbeddedConsumer.handleTopicEvent(KafkaServerStartable.scala:109)
at kafka.consumer.ZookeeperTopicEventWatcher$ZkTopicEventListener.liftedTree2$1(ZookeeperTopicEventWatcher.scala:83)
at kafka.consumer.ZookeeperTopicEventWatcher$ZkTopicEventListener.handleChildChange(ZookeeperTopicEventWatcher.scala:78)
at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:568)
at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
(kafka.consumer.ZookeeperTopicEventWatcher)

This happens since it tries to start a thread which has finished executing