[
https://issues.apache.org/jira/browse/KAFKA-3575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Taiyuan Zhang reassigned KAFKA-3575:
------------------------------------
Assignee: Taiyuan Zhang
> Use console consumer access topic that does not exist, can not use "Control +
> C" to exit process
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-3575
> URL: https://issues.apache.org/jira/browse/KAFKA-3575
> Project: Kafka
> Issue Type: Bug
> Components: core
> Affects Versions: 0.9.0.0
> Environment: SUSE Linux Enterprise Server 11 SP3
> Reporter: NieWang
> Assignee: Taiyuan Zhang
> Priority: Minor
> Fix For: 0.10.1.0
>
>
> 1. use "sh kafka-console-consumer.sh --zookeeper 10.252.23.133:2181 --topic
> topic_02" start console consumer. topic_02 does not exist.
> 2. you can not use "Control + C" to exit console consumer process. The
> process is blocked.
> 3. use jstack check process stack, as follows:
> linux:~ # jstack 122967
> 2016-04-18 15:46:06
> Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.66-b17 mixed mode):
> "Attach Listener" #29 daemon prio=9 os_prio=0 tid=0x0000000001781800
> nid=0x1e0c8 waiting on condition [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "Thread-4" #27 prio=5 os_prio=0 tid=0x00000000018a4000 nid=0x1e08a waiting on
> condition [0x00007ffbe5ac0000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e00ed3b8> (a
> java.util.concurrent.CountDownLatch$Sync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
> at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
> at kafka.tools.ConsoleConsumer$$anon$1.run(ConsoleConsumer.scala:101)
> "SIGINT handler" #28 daemon prio=9 os_prio=0 tid=0x00000000019d5800
> nid=0x1e089 in Object.wait() [0x00007ffbe5bc1000]
> java.lang.Thread.State: WAITING (on object monitor)
> at java.lang.Object.$$YJP$$wait(Native Method)
> at java.lang.Object.wait(Object.java)
> at java.lang.Thread.join(Thread.java:1245)
> - locked <0x00000000e71fd4e8> (a kafka.tools.ConsoleConsumer$$anon$1)
> at java.lang.Thread.join(Thread.java:1319)
> at
> java.lang.ApplicationShutdownHooks.runHooks(ApplicationShutdownHooks.java:106)
> at
> java.lang.ApplicationShutdownHooks$1.run(ApplicationShutdownHooks.java:46)
> at java.lang.Shutdown.runHooks(Shutdown.java:123)
> at java.lang.Shutdown.sequence(Shutdown.java:167)
> at java.lang.Shutdown.exit(Shutdown.java:212)
> - locked <0x00000000e00abfd8> (a java.lang.Class for
> java.lang.Shutdown)
> at java.lang.Terminator$1.handle(Terminator.java:52)
> at sun.misc.Signal$1.run(Signal.java:212)
> at java.lang.Thread.run(Thread.java:745)
> "metrics-meter-tick-thread-2" #20 daemon prio=5 os_prio=0
> tid=0x00007ffbec77a800 nid=0x1e079 waiting on condition [0x00007ffbe66c8000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e6fa6438> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> at
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> "metrics-meter-tick-thread-1" #19 daemon prio=5 os_prio=0
> tid=0x00007ffbec783000 nid=0x1e078 waiting on condition [0x00007ffbe67c9000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e6fa6438> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1081)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
> at
> java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> "main-EventThread" #17 daemon prio=5 os_prio=0 tid=0x00007ffbe08c8800
> nid=0x1e077 waiting on condition [0x00007ffbe6aca000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e6fa66a8> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> at
> org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:494)
> "main-SendThread(10.252.23.133:2181)" #16 daemon prio=5 os_prio=0
> tid=0x00007ffbe08c1000 nid=0x1e076 runnable [0x00007ffbe6bcb000]
> java.lang.Thread.State: RUNNABLE
> at sun.nio.ch.EPollArrayWrapper.$$YJP$$epollWait(Native Method)
> at sun.nio.ch.EPollArrayWrapper.epollWait(EPollArrayWrapper.java)
> at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
> at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:79)
> at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
> - locked <0x00000000e6fa6958> (a sun.nio.ch.Util$2)
> - locked <0x00000000e6fa6968> (a
> java.util.Collections$UnmodifiableSet)
> - locked <0x00000000e6fa6910> (a sun.nio.ch.EPollSelectorImpl)
> at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
> at
> org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:349)
> at
> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)
> "ZkClient-EventThread-15-10.252.23.133:2181" #15 daemon prio=5 os_prio=0
> tid=0x00007ffbe0812800 nid=0x1e075 waiting on condition [0x00007ffbe6f0b000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e6e0eae0> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:67)
> "Service Thread" #13 daemon prio=9 os_prio=0 tid=0x00007ffbe008c800
> nid=0x1e072 runnable [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "C1 CompilerThread2" #12 daemon prio=9 os_prio=0 tid=0x00007ffbe0054000
> nid=0x1e071 waiting on condition [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "C2 CompilerThread1" #11 daemon prio=9 os_prio=0 tid=0x0000000000f59000
> nid=0x1e070 waiting on condition [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "C2 CompilerThread0" #10 daemon prio=9 os_prio=0 tid=0x00007ffbe0047000
> nid=0x1e06f waiting on condition [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "YJPAgent-OOMESnapshotDetector" #9 daemon prio=10 os_prio=0
> tid=0x00007ffbec1dc000 nid=0x1e06e runnable [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "YJPAgent-CPUSampler" #8 daemon prio=10 os_prio=0 tid=0x00007ffbec1db800
> nid=0x1e06d runnable [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "YJPAgent-RequestListener" #7 daemon prio=1 os_prio=0 tid=0x00007ffbec1da800
> nid=0x1e06c runnable [0x00007ffbea0fd000]
> java.lang.Thread.State: RUNNABLE
> at java.net.PlainSocketImpl.$$YJP$$socketAccept(Native Method)
> at java.net.PlainSocketImpl.socketAccept(PlainSocketImpl.java)
> at
> java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
> at java.net.ServerSocket.implAccept(ServerSocket.java:545)
> at java.net.ServerSocket.accept(ServerSocket.java:513)
> at com.yourkit.runtime.Core$4.run(Core.java:726)
> at java.lang.Thread.run(Thread.java:745)
> "YJPAgent-Telemetry" #6 daemon prio=5 os_prio=0 tid=0x00007ffbec1ce800
> nid=0x1e06b waiting on condition [0x00007ffbea1fe000]
> java.lang.Thread.State: TIMED_WAITING (sleeping)
> at java.lang.Thread.$$YJP$$sleep(Native Method)
> at java.lang.Thread.sleep(Thread.java)
> at com.yourkit.util.Util.sleep(Util.java:64)
> at com.yourkit.runtime.TelemetryThread.run(TelemetryThread.java:579)
> "Signal Dispatcher" #5 daemon prio=9 os_prio=0 tid=0x0000000000d66000
> nid=0x1e06a runnable [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "Surrogate Locker Thread (Concurrent GC)" #4 daemon prio=9 os_prio=0
> tid=0x0000000000dfc800 nid=0x1e069 waiting on condition [0x0000000000000000]
> java.lang.Thread.State: RUNNABLE
> "Finalizer" #3 daemon prio=8 os_prio=0 tid=0x0000000000c0a000 nid=0x1e068 in
> Object.wait() [0x00007ffbea81f000]
> java.lang.Thread.State: WAITING (on object monitor)
> at java.lang.Object.$$YJP$$wait(Native Method)
> at java.lang.Object.wait(Object.java)
> at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
> - locked <0x00000000e00c6d50> (a java.lang.ref.ReferenceQueue$Lock)
> at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
> at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)
> "Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x0000000000bf9000
> nid=0x1e067 in Object.wait() [0x00007ffbea920000]
> java.lang.Thread.State: WAITING (on object monitor)
> at java.lang.Object.$$YJP$$wait(Native Method)
> at java.lang.Object.wait(Object.java)
> at java.lang.Object.wait(Object.java:502)
> at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:157)
> - locked <0x00000000e00c6f08> (a java.lang.ref.Reference$Lock)
> "main" #1 prio=5 os_prio=0 tid=0x000000000079a800 nid=0x1e05a waiting on
> condition [0x00007ffc034b4000]
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000e6f510e0> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> at
> java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> 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 kafka.consumer.OldConsumer.receive(BaseConsumer.scala:79)
> at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:110)
> at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:69)
> at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:47)
> at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
> "VM Thread" os_prio=0 tid=0x0000000000be9000 nid=0x1e066 runnable
> "Gang worker#0 (Parallel GC Threads)" os_prio=0 tid=0x00000000007e6800
> nid=0x1e05b runnable
> "Gang worker#1 (Parallel GC Threads)" os_prio=0 tid=0x00000000007e8000
> nid=0x1e05c runnable
> "Gang worker#2 (Parallel GC Threads)" os_prio=0 tid=0x00000000007e9800
> nid=0x1e05d runnable
> "Gang worker#3 (Parallel GC Threads)" os_prio=0 tid=0x00000000007eb000
> nid=0x1e05e runnable
> "G1 Main Concurrent Mark GC Thread" os_prio=0 tid=0x0000000000820000
> nid=0x1e064 runnable
> "Gang worker#0 (G1 Parallel Marking Threads)" os_prio=0
> tid=0x0000000000822000 nid=0x1e065 runnable
> "G1 Concurrent Refinement Thread#0" os_prio=0 tid=0x00000000007f5000
> nid=0x1e063 runnable
> "G1 Concurrent Refinement Thread#1" os_prio=0 tid=0x00000000007f3000
> nid=0x1e062 runnable
> "G1 Concurrent Refinement Thread#2" os_prio=0 tid=0x00000000007f1800
> nid=0x1e061 runnable
> "G1 Concurrent Refinement Thread#3" os_prio=0 tid=0x00000000007ef800
> nid=0x1e060 runnable
> "G1 Concurrent Refinement Thread#4" os_prio=0 tid=0x00000000007ed800
> nid=0x1e05f runnable
> "VM Periodic Task Thread" os_prio=0 tid=0x00007ffbec1fc800 nid=0x1e073
> waiting on condition
> JNI global references: 7020
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
