[
https://issues.apache.org/jira/browse/KAFKA-212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-212:
--------------------------------
Resolution: Fixed
Status: Resolved (was: Patch Available)
Fix is committed
> 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
>
> Attachments: KAFKA-212.patch
>
>
> 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
