[jira] [Created] (KAFKA-1385) mirrormaker hangs during shutdown if no topic is consumed

["Jun Rao (JIRA)" <ji...@apache.org>]

Jun Rao created KAFKA-1385:
------------------------------

             Summary: mirrormaker hangs during shutdown if no topic is consumed
                 Key: KAFKA-1385
                 URL: https://issues.apache.org/jira/browse/KAFKA-1385
             Project: Kafka
          Issue Type: Bug
          Components: core
    Affects Versions: 0.8.2
            Reporter: Jun Rao


Couldn't do clean shutdown when running the following command.

bin/kafka-run-class.sh kafka.tools.MirrorMaker --producer.config config/producer.properties --consumer.config config/consumer.properties --blacklist=".*"

Saw the following stacktrace.

"Thread-6" prio=5 tid=7f94120af800 nid=0x113e16000 waiting on condition [113e15000]
   java.lang.Thread.State: WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        - parking to wait for  <7ec0eb870> (a java.util.concurrent.CountDownLatch$Sync)
        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:969)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1281)
        at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:207)
        at kafka.tools.MirrorMaker$MirrorMakerThread.awaitShutdown(MirrorMaker.scala:216)
        at kafka.tools.MirrorMaker$$anonfun$cleanShutdown$2.apply(MirrorMaker.scala:167)
        at kafka.tools.MirrorMaker$$anonfun$cleanShutdown$2.apply(MirrorMaker.scala:167)
        at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
        at scala.collection.immutable.List.foreach(List.scala:45)
        at kafka.tools.MirrorMaker$.cleanShutdown(MirrorMaker.scala:167)
        at kafka.tools.MirrorMaker$$anon$2.run(MirrorMaker.scala:144)


"mirrormaker-0" prio=5 tid=7f9414a90800 nid=0x113804000 waiting on condition [113803000]
   java.lang.Thread.State: WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        - parking to wait for  <7ec0b0298> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1987)
        at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:399)
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:63)
        at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
        at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:66)
        at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:58)
        at scala.collection.Iterator$class.foreach(Iterator.scala:631)
        at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
        at scala.collection.IterableLike$class.foreach(IterableLike.scala:79)
        at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:25)
        at kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:190)




--
This message was sent by Atlassian JIRA
(v6.2#6252)