IllegalThreadStateException in topic watcher for Kafka mirroring
----------------------------------------------------------------
Key: KAFKA-212
URL: https://issues.apache.org/jira/browse/KAFKA-212
Project: Kafka
Issue Type: Bug
Reporter: Neha Narkhede
Assignee: Neha Narkhede
Fix For: 0.7.1
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
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
