2023-04-15 02:10:44 Full thread dump OpenJDK 64-Bit Server VM (11.0.14+9-LTS mixed mode): Threads class SMR info: _java_thread_list=0x0000fff8a4002a20, length=126, elements={ 0x0000ffff8402a000, 0x0000ffff846d8800, 0x0000ffff846dc800, 0x0000ffff846f4000, 0x0000ffff846f6000, 0x0000ffff846f8000, 0x0000ffff846fa000, 0x0000ffff846fc000, 0x0000ffff847a8000, 0x0000ffff84da3800, 0x0000ffff84da9800, 0x0000ffff84dda800, 0x0000ffff868fe800, 0x0000ffff86924000, 0x0000ffff86925800, 0x0000ffff86957800, 0x0000ffff8697e800, 0x0000ffff86980800, 0x0000ffff86999800, 0x0000ffff8699d000, 0x0000ffff8699f800, 0x0000ffff86a2b000, 0x0000ffff86a2e000, 0x0000ffff86a5f800, 0x0000ffff86a81000, 0x0000ffff86bbf000, 0x0000ffff86bd6800, 0x0000ffff86bd8800, 0x0000ffff86bdb000, 0x0000fffea808a000, 0x0000fffea808b000, 0x0000fffea8092800, 0x0000ffff24001000, 0x0000fffea80c0800, 0x0000fffea80c5800, 0x0000fffea80b9000, 0x0000fffea80bb800, 0x0000fffea80bc000, 0x0000fffea80cb800, 0x0000fffea80cc000, 0x0000ffff84e85800, 0x0000ffff86480000, 0x0000ffff865cc000, 0x0000fffe2c002000, 0x0000fffe2c045800, 0x0000fffe2c047000, 0x0000fffe2c049000, 0x0000fffe2c04b000, 0x0000fffe2c04d800, 0x0000fffe2c04f800, 0x0000fffe2c051800, 0x0000fffe2c053800, 0x0000fffe2c056000, 0x0000fffe2c058000, 0x0000fffe2c05a000, 0x0000fffe2c05c800, 0x0000fffe2c05e800, 0x0000fffe2c060800, 0x0000fffe2c062800, 0x0000ffff8660b000, 0x0000ffff86616000, 0x0000ffff86617000, 0x0000ffff86618800, 0x0000ffff8661e000, 0x0000ffff86632000, 0x0000ffff85503800, 0x0000ffff85583000, 0x0000ffff85584800, 0x0000ffff85588800, 0x0000ffff8558b800, 0x0000ffff855c9800, 0x0000ffff855f9000, 0x0000ffff855fb000, 0x0000ffff8568b000, 0x0000ffff85694800, 0x0000ffff8574d000, 0x0000ffff85728000, 0x0000ffff85729800, 0x0000ffff8572f000, 0x0000ffff85731000, 0x0000ffff85734000, 0x0000ffff85736000, 0x0000ffff85738000, 0x0000ffff8573a000, 0x0000ffff8573c800, 0x0000ffff8573e800, 0x0000ffff85740000, 0x0000ffff85742000, 0x0000ffff85744000, 0x0000ffff85746000, 0x0000ffff85748800, 0x0000ffff8574a800, 0x0000ffff8569e800, 0x0000ffff856a0000, 0x0000ffff856a2800, 0x0000ffff856a4000, 0x0000ffff856a6800, 0x0000ffff856a8800, 0x0000ffff856aa800, 0x0000ffff856ac800, 0x0000ffff856bf000, 0x0000ffff856c9800, 0x0000ffff856d4000, 0x0000ffff856d6000, 0x0000ffff856d8000, 0x0000ffff856da000, 0x0000ffff856dc000, 0x0000ffff856de000, 0x0000ffff856e0000, 0x0000ffff856e2000, 0x0000fff86470c000, 0x0000fff864712000, 0x0000fff864717800, 0x0000fff86471d800, 0x0000fff864723800, 0x0000fff864736000, 0x0000fffe400e7000, 0x0000fff8c8001000, 0x0000fff8a8008800, 0x0000fff8a4003000, 0x0000fff8c4006000, 0x0000fff87803c800, 0x0000fff878017000, 0x0000ffff04008000, 0x0000ffff04004800, 0x0000ffff04009800 } "main" #1 prio=5 os_prio=0 cpu=2209.67ms elapsed=968483.10s tid=0x0000ffff8402a000 nid=0x190 waiting on condition [0x0000ffff8826b000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66cb6b0> (a java.util.concurrent.CountDownLatch$Sync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(java.base@11.0.14/AbstractQueuedSynchronizer.java:1039) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(java.base@11.0.14/AbstractQueuedSynchronizer.java:1345) at java.util.concurrent.CountDownLatch.await(java.base@11.0.14/CountDownLatch.java:232) at kafka.server.KafkaServer.awaitShutdown(KafkaServer.scala:683) at kafka.server.KafkaServerStartable.awaitShutdown(KafkaServerStartable.scala:71) at kafka.Kafka$.main(Kafka.scala:85) at kafka.Kafka.main(Kafka.scala) "Reference Handler" #2 daemon prio=10 os_prio=0 cpu=2108.92ms elapsed=968483.04s tid=0x0000ffff846d8800 nid=0x197 waiting on condition [0x0000ffff3f7fe000] java.lang.Thread.State: RUNNABLE at java.lang.ref.Reference.waitForReferencePendingList(java.base@11.0.14/Native Method) at java.lang.ref.Reference.processPendingReferences(java.base@11.0.14/Reference.java:241) at java.lang.ref.Reference$ReferenceHandler.run(java.base@11.0.14/Reference.java:213) "Finalizer" #3 daemon prio=8 os_prio=0 cpu=715.41ms elapsed=968483.04s tid=0x0000ffff846dc800 nid=0x198 in Object.wait() [0x0000ffff3f5fe000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.ref.ReferenceQueue.remove(java.base@11.0.14/ReferenceQueue.java:155) - waiting to re-lock in wait() <0x0000000580001c88> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.14/ReferenceQueue.java:176) at java.lang.ref.Finalizer$FinalizerThread.run(java.base@11.0.14/Finalizer.java:170) "Signal Dispatcher" #4 daemon prio=9 os_prio=0 cpu=0.23ms elapsed=968483.04s tid=0x0000ffff846f4000 nid=0x199 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Service Thread" #5 daemon prio=9 os_prio=0 cpu=0.10ms elapsed=968483.04s tid=0x0000ffff846f6000 nid=0x19a runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread0" #6 daemon prio=9 os_prio=0 cpu=78928.46ms elapsed=968483.04s tid=0x0000ffff846f8000 nid=0x19b waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task "C1 CompilerThread0" #14 daemon prio=9 os_prio=0 cpu=7142.17ms elapsed=968483.04s tid=0x0000ffff846fa000 nid=0x19c waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task "Sweeper thread" #18 daemon prio=9 os_prio=0 cpu=280.15ms elapsed=968483.03s tid=0x0000ffff846fc000 nid=0x19d runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Common-Cleaner" #19 daemon prio=8 os_prio=0 cpu=345.65ms elapsed=968482.98s tid=0x0000ffff847a8000 nid=0x19e in Object.wait() [0x0000ffff3e9ad000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.ref.ReferenceQueue.remove(java.base@11.0.14/ReferenceQueue.java:155) - waiting to re-lock in wait() <0x0000000580004aa0> (a java.lang.ref.ReferenceQueue$Lock) at jdk.internal.ref.CleanerImpl.run(java.base@11.0.14/CleanerImpl.java:148) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) at jdk.internal.misc.InnocuousThread.run(java.base@11.0.14/InnocuousThread.java:161) "RMI TCP Accept-0" #21 daemon prio=5 os_prio=0 cpu=3371.46ms elapsed=968482.38s tid=0x0000ffff84da3800 nid=0x1a2 runnable [0x0000ffff3e343000] java.lang.Thread.State: RUNNABLE at java.net.PlainSocketImpl.socketAccept(java.base@11.0.14/Native Method) at java.net.AbstractPlainSocketImpl.accept(java.base@11.0.14/AbstractPlainSocketImpl.java:474) at java.net.ServerSocket.implAccept(java.base@11.0.14/ServerSocket.java:565) at java.net.ServerSocket.accept(java.base@11.0.14/ServerSocket.java:533) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(java.rmi@11.0.14/TCPTransport.java:394) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(java.rmi@11.0.14/TCPTransport.java:366) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "RMI TCP Accept-9999" #22 daemon prio=5 os_prio=0 cpu=1157.49ms elapsed=968482.37s tid=0x0000ffff84da9800 nid=0x1a3 runnable [0x0000ffff3dce0000] java.lang.Thread.State: RUNNABLE at java.net.PlainSocketImpl.socketAccept(java.base@11.0.14/Native Method) at java.net.AbstractPlainSocketImpl.accept(java.base@11.0.14/AbstractPlainSocketImpl.java:474) at java.net.ServerSocket.implAccept(java.base@11.0.14/ServerSocket.java:565) at java.net.ServerSocket.accept(java.base@11.0.14/ServerSocket.java:533) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(java.rmi@11.0.14/TCPTransport.java:394) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(java.rmi@11.0.14/TCPTransport.java:366) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "RMI TCP Accept-0" #23 daemon prio=5 os_prio=0 cpu=0.11ms elapsed=968482.34s tid=0x0000ffff84dda800 nid=0x1a4 runnable [0x0000ffff3dae0000] java.lang.Thread.State: RUNNABLE at java.net.PlainSocketImpl.socketAccept(java.base@11.0.14/Native Method) at java.net.AbstractPlainSocketImpl.accept(java.base@11.0.14/AbstractPlainSocketImpl.java:474) at java.net.ServerSocket.implAccept(java.base@11.0.14/ServerSocket.java:565) at java.net.ServerSocket.accept(java.base@11.0.14/ServerSocket.java:533) at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(jdk.management.agent@11.0.14/LocalRMIServerSocketFactory.java:52) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(java.rmi@11.0.14/TCPTransport.java:394) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(java.rmi@11.0.14/TCPTransport.java:366) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Apollo-ConfigServiceLocator-1" #26 daemon prio=5 os_prio=0 cpu=2342.21ms elapsed=968481.47s tid=0x0000ffff868fe800 nid=0x1aa waiting on condition [0x0000ffff3c68a000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005800028f8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Apollo-RemoteConfigRepository-1" #27 daemon prio=5 os_prio=0 cpu=90482.50ms elapsed=968481.39s tid=0x0000ffff86924000 nid=0x1ab waiting on condition [0x0000ffff3c447000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005800065b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Apollo-RemoteConfigLongPollService-1" #28 daemon prio=5 os_prio=0 cpu=6451.23ms elapsed=968481.39s tid=0x0000ffff86925800 nid=0x1ac runnable [0x0000ffff3c246000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.14/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.14/SocketInputStream.java:115) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:168) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:140) at java.io.BufferedInputStream.fill(java.base@11.0.14/BufferedInputStream.java:252) at java.io.BufferedInputStream.read1(java.base@11.0.14/BufferedInputStream.java:292) at java.io.BufferedInputStream.read(java.base@11.0.14/BufferedInputStream.java:351) - locked <0x00000005a2876a70> (a java.io.BufferedInputStream) at sun.net.www.http.HttpClient.parseHTTPHeader(java.base@11.0.14/HttpClient.java:754) at sun.net.www.http.HttpClient.parseHTTP(java.base@11.0.14/HttpClient.java:689) at sun.net.www.protocol.http.HttpURLConnection.getInputStream0(java.base@11.0.14/HttpURLConnection.java:1615) - locked <0x00000005a2876b08> (a sun.net.www.protocol.http.HttpURLConnection) at sun.net.www.protocol.http.HttpURLConnection.getInputStream(java.base@11.0.14/HttpURLConnection.java:1520) - locked <0x00000005a2876b08> (a sun.net.www.protocol.http.HttpURLConnection) at java.net.HttpURLConnection.getResponseCode(java.base@11.0.14/HttpURLConnection.java:527) at com.ctrip.framework.apollo.util.http.HttpUtil.doGetWithSerializeFunction(HttpUtil.java:96) at com.ctrip.framework.apollo.util.http.HttpUtil.doGet(HttpUtil.java:68) at com.ctrip.framework.apollo.internals.RemoteConfigLongPollService.doLongPollingRefresh(RemoteConfigLongPollService.java:170) at com.ctrip.framework.apollo.internals.RemoteConfigLongPollService.access$100(RemoteConfigLongPollService.java:50) at com.ctrip.framework.apollo.internals.RemoteConfigLongPollService$2.run(RemoteConfigLongPollService.java:124) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.14/Executors.java:515) at java.util.concurrent.FutureTask.run(java.base@11.0.14/FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Metric-Producer" #29 prio=5 os_prio=0 cpu=110982.68ms elapsed=968481.34s tid=0x0000ffff86957800 nid=0x1ad in Object.wait() [0x0000fffee3dfe000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.14/Object.java:328) at com.tuya.lmax.disruptor.disruptor.LiteBlockingWaitStrategy.waitFor(LiteBlockingWaitStrategy.java:52) - waiting to re-lock in wait() <0x00000005800052b0> (a java.lang.Object) at com.tuya.lmax.disruptor.disruptor.ProcessingSequenceBarrier.waitFor(ProcessingSequenceBarrier.java:56) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.processEvents(BatchEventProcessor.java:159) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:125) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Package-Producer" #30 prio=5 os_prio=0 cpu=49192.51ms elapsed=968481.32s tid=0x0000ffff8697e800 nid=0x1ae in Object.wait() [0x0000fffee3bfe000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.14/Object.java:328) at com.tuya.lmax.disruptor.disruptor.LiteBlockingWaitStrategy.waitFor(LiteBlockingWaitStrategy.java:52) - waiting to re-lock in wait() <0x0000000580001f98> (a java.lang.Object) at com.tuya.lmax.disruptor.disruptor.ProcessingSequenceBarrier.waitFor(ProcessingSequenceBarrier.java:56) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.processEvents(BatchEventProcessor.java:159) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:125) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Push-Metric-Timer" #31 prio=5 os_prio=0 cpu=15351.14ms elapsed=968481.32s tid=0x0000ffff86980800 nid=0x1af waiting on condition [0x0000fffee39fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005800075d0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "MessageSender" #33 daemon prio=5 os_prio=0 cpu=12600.48ms elapsed=968481.32s tid=0x0000ffff86999800 nid=0x1b0 in Object.wait() [0x0000fffee37fe000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.14/Object.java:328) at com.tuya.lmax.disruptor.disruptor.LiteBlockingWaitStrategy.waitFor(LiteBlockingWaitStrategy.java:52) - waiting to re-lock in wait() <0x0000000580005da0> (a java.lang.Object) at com.tuya.lmax.disruptor.disruptor.ProcessingSequenceBarrier.waitFor(ProcessingSequenceBarrier.java:56) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.processEvents(BatchEventProcessor.java:159) at com.tuya.lmax.disruptor.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:125) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "HeartBeat-Scheduled-Executor" #35 prio=5 os_prio=0 cpu=58325.63ms elapsed=968481.32s tid=0x0000ffff8699d000 nid=0x1b1 waiting on condition [0x0000fffee35fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005800032b8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "metrics-tuya-thread-1" #37 daemon prio=5 os_prio=0 cpu=934474.59ms elapsed=968481.32s tid=0x0000ffff8699f800 nid=0x1b2 waiting on condition [0x0000fffee33fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580006f30> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "metrics-meter-tick-thread-1" #39 daemon prio=5 os_prio=0 cpu=1045944.04ms elapsed=968481.22s tid=0x0000ffff86a2b000 nid=0x1b3 waiting on condition [0x0000fffee2ffe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580002380> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "metrics-meter-tick-thread-2" #40 daemon prio=5 os_prio=0 cpu=1099636.00ms elapsed=968481.22s tid=0x0000ffff86a2e000 nid=0x1b4 waiting on condition [0x0000fffee2dfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580002380> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "main-SendThread(172.16.31.54:12181)" #43 daemon prio=5 os_prio=0 cpu=11649.76ms elapsed=968481.01s tid=0x0000ffff86a5f800 nid=0x1b7 runnable [0x0000ffff3d6de000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005800057d0> (a sun.nio.ch.Util$2) - locked <0x00000005800055f8> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:345) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1223) "main-EventThread" #44 daemon prio=5 os_prio=0 cpu=42.27ms elapsed=968481.01s tid=0x0000ffff86a81000 nid=0x1b8 waiting on condition [0x0000fffee29fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580004d90> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:506) "SensorExpiryThread" #45 daemon prio=5 os_prio=0 cpu=2084.08ms elapsed=968480.73s tid=0x0000ffff86bbf000 nid=0x1ba waiting on condition [0x0000fffee23fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580002be8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "ThrottledChannelReaper-Fetch" #46 prio=5 os_prio=0 cpu=13863.12ms elapsed=968480.71s tid=0x0000ffff86bd6800 nid=0x1bb waiting on condition [0x0000fffee21fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580006048> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.server.ClientQuotaManager$ThrottledChannelReaper.doWork(ClientQuotaManager.scala:196) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ThrottledChannelReaper-Produce" #47 prio=5 os_prio=0 cpu=13879.33ms elapsed=968480.71s tid=0x0000ffff86bd8800 nid=0x1bc waiting on condition [0x0000fffee1ffe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005800033a0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.server.ClientQuotaManager$ThrottledChannelReaper.doWork(ClientQuotaManager.scala:196) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ThrottledChannelReaper-Request" #48 prio=5 os_prio=0 cpu=14316.06ms elapsed=968480.71s tid=0x0000ffff86bdb000 nid=0x1bd waiting on condition [0x0000fffee1dfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580002448> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.server.ClientQuotaManager$ThrottledChannelReaper.doWork(ClientQuotaManager.scala:196) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "kafka-scheduler-0" #50 daemon prio=5 os_prio=0 cpu=255930.46ms elapsed=968480.31s tid=0x0000fffea808a000 nid=0x1c0 waiting on condition [0x0000fffee2bfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-1" #51 daemon prio=5 os_prio=0 cpu=255446.89ms elapsed=968480.30s tid=0x0000fffea808b000 nid=0x1c1 waiting on condition [0x0000fffee03fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-2" #52 daemon prio=5 os_prio=0 cpu=259575.73ms elapsed=968480.29s tid=0x0000fffea8092800 nid=0x1c2 waiting on condition [0x0000fffee01fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(java.base@11.0.14/AbstractQueuedSynchronizer.java:917) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(java.base@11.0.14/AbstractQueuedSynchronizer.java:1240) at java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:959) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:261) at kafka.cluster.Partition.maybeShrinkIsr(Partition.scala:836) at kafka.server.ReplicaManager.$anonfun$maybeShrinkIsr$3(ReplicaManager.scala:1546) at kafka.server.ReplicaManager.$anonfun$maybeShrinkIsr$3$adapted(ReplicaManager.scala:1546) at kafka.server.ReplicaManager$$Lambda$1187/0x0000000800829040.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.ReplicaManager.$anonfun$maybeShrinkIsr$2(ReplicaManager.scala:1546) at kafka.server.ReplicaManager.$anonfun$maybeShrinkIsr$2$adapted(ReplicaManager.scala:1545) at kafka.server.ReplicaManager$$Lambda$691/0x000000080067b840.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.server.ReplicaManager.maybeShrinkIsr(ReplicaManager.scala:1545) at kafka.server.ReplicaManager.$anonfun$startup$1(ReplicaManager.scala:327) at kafka.server.ReplicaManager$$Lambda$683/0x0000000800678c40.apply$mcV$sp(Unknown Source) at kafka.utils.KafkaScheduler.$anonfun$schedule$2(KafkaScheduler.scala:116) at kafka.utils.KafkaScheduler$$Lambda$416/0x00000008004b7440.apply$mcV$sp(Unknown Source) at kafka.utils.CoreUtils$$anon$1.run(CoreUtils.scala:65) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.14/Executors.java:515) at java.util.concurrent.FutureTask.runAndReset(java.base@11.0.14/FutureTask.java:305) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(java.base@11.0.14/ScheduledThreadPoolExecutor.java:305) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "Attach Listener" #53 daemon prio=9 os_prio=0 cpu=195.48ms elapsed=968479.57s tid=0x0000ffff24001000 nid=0x1e3 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "kafka-scheduler-3" #54 daemon prio=5 os_prio=0 cpu=255714.37ms elapsed=968477.62s tid=0x0000fffea80c0800 nid=0x1f0 waiting on condition [0x0000ffff3d2de000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-4" #55 daemon prio=5 os_prio=0 cpu=256740.24ms elapsed=968475.33s tid=0x0000fffea80c5800 nid=0x1f3 waiting on condition [0x0000ffff3e7ad000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-5" #56 daemon prio=5 os_prio=0 cpu=250482.42ms elapsed=968474.72s tid=0x0000fffea80b9000 nid=0x1f5 waiting on condition [0x0000fffea01fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-6" #57 daemon prio=5 os_prio=0 cpu=257238.23ms elapsed=968474.71s tid=0x0000fffea80bb800 nid=0x1f6 waiting on condition [0x0000fffea03fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-7" #58 daemon prio=5 os_prio=0 cpu=245571.55ms elapsed=968472.00s tid=0x0000fffea80bc000 nid=0x1f7 waiting on condition [0x0000ffff3e5ad000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-8" #59 daemon prio=5 os_prio=0 cpu=257942.32ms elapsed=968471.99s tid=0x0000fffea80cb800 nid=0x1f8 waiting on condition [0x0000fffe983fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-scheduler-9" #60 daemon prio=5 os_prio=0 cpu=253054.29ms elapsed=968466.49s tid=0x0000fffea80cc000 nid=0x1f9 waiting on condition [0x0000ffff3c88a000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580007170> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1177) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "kafka-log-cleaner-thread-0" #69 prio=5 os_prio=0 cpu=127435.17ms elapsed=967960.26s tid=0x0000ffff84e85800 nid=0x212 waiting on condition [0x0000fffee1bfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66d0588> (a java.util.concurrent.CountDownLatch$Sync) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:1079) at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:1369) at java.util.concurrent.CountDownLatch.await(java.base@11.0.14/CountDownLatch.java:278) at kafka.utils.ShutdownableThread.pause(ShutdownableThread.scala:82) at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:315) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "data-plane-kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-9092" #70 prio=5 os_prio=0 cpu=76942.84ms elapsed=967960.04s tid=0x0000ffff86480000 nid=0x214 waiting on condition [0x0000fffe83dfd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6706e60> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.Processor.accept(SocketServer.scala:1020) at kafka.network.Acceptor.assignNewConnection(SocketServer.scala:660) at kafka.network.Acceptor.$anonfun$run$1(SocketServer.scala:587) at kafka.network.Acceptor.$anonfun$run$1$adapted(SocketServer.scala:571) at kafka.network.Acceptor$$Lambda$746/0x00000008006b1840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.network.Acceptor.run(SocketServer.scala:571) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "pool-10-thread-1" #71 prio=5 os_prio=0 cpu=11882.28ms elapsed=967959.79s tid=0x0000ffff865cc000 nid=0x215 runnable [0x0000fffee0a1a000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d2cb0> (a sun.nio.ch.Util$2) - locked <0x00000005c66d2c58> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:340) at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:194) at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 1" #72 prio=5 os_prio=0 cpu=12588.69ms elapsed=967959.78s tid=0x0000fffe2c002000 nid=0x216 runnable [0x0000fffe385fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66da198> (a sun.nio.ch.Util$2) - locked <0x00000005c66da140> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 2" #73 prio=5 os_prio=0 cpu=12143.80ms elapsed=967959.78s tid=0x0000fffe2c045800 nid=0x217 runnable [0x0000fffe383fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66dc890> (a sun.nio.ch.Util$2) - locked <0x00000005c66dc838> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 3" #74 prio=5 os_prio=0 cpu=11906.63ms elapsed=967959.78s tid=0x0000fffe2c047000 nid=0x218 runnable [0x0000fffe381fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d5658> (a sun.nio.ch.Util$2) - locked <0x00000005c66d5600> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 4" #75 prio=5 os_prio=0 cpu=12342.04ms elapsed=967959.78s tid=0x0000fffe2c049000 nid=0x219 runnable [0x0000fffe303fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66da528> (a sun.nio.ch.Util$2) - locked <0x00000005c66da4d0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 5" #76 prio=5 os_prio=0 cpu=12193.00ms elapsed=967959.78s tid=0x0000fffe2c04b000 nid=0x21a runnable [0x0000fffe301fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d3088> (a sun.nio.ch.Util$2) - locked <0x00000005c66d3030> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 6" #77 prio=5 os_prio=0 cpu=11821.48ms elapsed=967959.78s tid=0x0000fffe2c04d800 nid=0x21b runnable [0x0000fffa9b7fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d5898> (a sun.nio.ch.Util$2) - locked <0x00000005c66d5840> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 7" #78 prio=5 os_prio=0 cpu=12231.60ms elapsed=967959.78s tid=0x0000fffe2c04f800 nid=0x21c runnable [0x0000fffa9b5fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d0810> (a sun.nio.ch.Util$2) - locked <0x00000005c66d07b8> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 8" #79 prio=5 os_prio=0 cpu=12441.59ms elapsed=967959.78s tid=0x0000fffe2c051800 nid=0x21d runnable [0x0000fffa9b3fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66da768> (a sun.nio.ch.Util$2) - locked <0x00000005c66da710> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 9" #80 prio=5 os_prio=0 cpu=12105.90ms elapsed=967959.78s tid=0x0000fffe2c053800 nid=0x21e runnable [0x0000fffa9b1fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66dcad0> (a sun.nio.ch.Util$2) - locked <0x00000005c66dca78> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 10" #81 prio=5 os_prio=0 cpu=12152.60ms elapsed=967959.78s tid=0x0000fffe2c056000 nid=0x21f runnable [0x0000fffa9affe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66def88> (a sun.nio.ch.Util$2) - locked <0x00000005c66def30> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 11" #82 prio=5 os_prio=0 cpu=12004.64ms elapsed=967959.78s tid=0x0000fffe2c058000 nid=0x220 runnable [0x0000fffa9adfe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d5ad8> (a sun.nio.ch.Util$2) - locked <0x00000005c66d5a80> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 12" #83 prio=5 os_prio=0 cpu=12424.07ms elapsed=967959.78s tid=0x0000fffe2c05a000 nid=0x221 runnable [0x0000fffa9abfe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66e1680> (a sun.nio.ch.Util$2) - locked <0x00000005c66e1628> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 13" #84 prio=5 os_prio=0 cpu=12315.01ms elapsed=967959.78s tid=0x0000fffe2c05c800 nid=0x222 runnable [0x0000fffa9a9fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66da9a8> (a sun.nio.ch.Util$2) - locked <0x00000005c66da950> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 14" #85 prio=5 os_prio=0 cpu=11739.68ms elapsed=967959.78s tid=0x0000fffe2c05e800 nid=0x223 runnable [0x0000fffa9a7fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d32c8> (a sun.nio.ch.Util$2) - locked <0x00000005c66d3270> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 15" #86 prio=5 os_prio=0 cpu=12113.16ms elapsed=967959.78s tid=0x0000fffe2c060800 nid=0x224 runnable [0x0000fffa9a5fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66dcd10> (a sun.nio.ch.Util$2) - locked <0x00000005c66dccb8> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "I/O dispatcher 16" #87 prio=5 os_prio=0 cpu=11556.64ms elapsed=967959.78s tid=0x0000fffe2c062800 nid=0x225 runnable [0x0000fffa917fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d5e20> (a sun.nio.ch.Util$2) - locked <0x00000005c66d5cc0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.http.impl.nio.reactor.AbstractIOReactor.execute(AbstractIOReactor.java:255) at org.apache.http.impl.nio.reactor.BaseIOReactor.execute(BaseIOReactor.java:104) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor$Worker.run(AbstractMultiworkerIOReactor.java:588) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-socket-acceptor-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-9093" #88 prio=5 os_prio=0 cpu=80446.40ms elapsed=967959.53s tid=0x0000ffff8660b000 nid=0x226 waiting on condition [0x0000fffa913fd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c67d9a48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.Processor.accept(SocketServer.scala:1020) at kafka.network.Acceptor.assignNewConnection(SocketServer.scala:660) at kafka.network.Acceptor.$anonfun$run$1(SocketServer.scala:587) at kafka.network.Acceptor.$anonfun$run$1$adapted(SocketServer.scala:571) at kafka.network.Acceptor$$Lambda$746/0x00000008006b1840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.network.Acceptor.run(SocketServer.scala:571) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "ExpirationReaper-7-Produce" #89 prio=5 os_prio=0 cpu=214432.10ms elapsed=967959.51s tid=0x0000ffff86616000 nid=0x227 waiting on condition [0x0000fffa911fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66d0a18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:274) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-Fetch" #90 prio=5 os_prio=0 cpu=10407711.75ms elapsed=967959.51s tid=0x0000ffff86617000 nid=0x228 waiting on condition [0x0000fffa90ffe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66dac30> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-DeleteRecords" #91 prio=5 os_prio=0 cpu=62795.50ms elapsed=967959.50s tid=0x0000ffff86618800 nid=0x229 waiting on condition [0x0000fffa90dfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66d34d0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-ElectLeader" #92 prio=5 os_prio=0 cpu=62793.24ms elapsed=967959.50s tid=0x0000ffff8661e000 nid=0x22a waiting on condition [0x0000fffa90bfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66dcf18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "tuya-replica-selector" #93 daemon prio=5 os_prio=0 cpu=2235.40ms elapsed=967959.49s tid=0x0000ffff86632000 nid=0x22b waiting on condition [0x0000fffa909fe000] java.lang.Thread.State: TIMED_WAITING (sleeping) at java.lang.Thread.sleep(java.base@11.0.14/Native Method) at com.tuya.kafka.server.replica.TuyaReplicaSelector.loop(TuyaReplicaSelector.java:47) at com.tuya.kafka.server.replica.TuyaReplicaSelector$$Lambda$682/0x0000000800678840.run(Unknown Source) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "LogDirFailureHandler" #94 prio=5 os_prio=0 cpu=0.18ms elapsed=967959.49s tid=0x0000ffff85503800 nid=0x22c waiting on condition [0x0000fffa905fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x000000058008b4d0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.take(java.base@11.0.14/ArrayBlockingQueue.java:417) at kafka.server.LogDirFailureChannel.takeNextOfflineLogDir(LogDirFailureChannel.scala:56) at kafka.server.ReplicaManager$LogDirFailureHandler.doWork(ReplicaManager.scala:222) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "controller-event-thread" #95 prio=5 os_prio=0 cpu=8.33ms elapsed=967959.38s tid=0x0000ffff85583000 nid=0x22d waiting on condition [0x0000fffa7ebfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66e3f80> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at kafka.controller.ControllerEventManager$ControllerEventThread.doWork(ControllerEventManager.scala:127) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-topic" #96 prio=5 os_prio=0 cpu=63528.78ms elapsed=967959.37s tid=0x0000ffff85584800 nid=0x22e waiting on condition [0x0000fffa7e9fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66e6438> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-Heartbeat" #97 prio=5 os_prio=0 cpu=91736.38ms elapsed=967959.37s tid=0x0000ffff85588800 nid=0x22f waiting on condition [0x0000fffa7e7fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66df418> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ExpirationReaper-7-Rebalance" #98 prio=5 os_prio=0 cpu=64327.57ms elapsed=967959.37s tid=0x0000ffff8558b800 nid=0x230 waiting on condition [0x0000fffa7e5fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66d0c58> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "group-metadata-manager-0" #99 daemon prio=5 os_prio=0 cpu=3183.22ms elapsed=967959.34s tid=0x0000ffff855c9800 nid=0x231 waiting on condition [0x0000fffa7e3fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66cb848> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "transaction-log-manager-0" #102 daemon prio=5 os_prio=0 cpu=1112.64ms elapsed=967959.31s tid=0x0000ffff855f9000 nid=0x232 waiting on condition [0x0000fffa7dffe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66e41f0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "TxnMarkerSenderThread-7" #101 prio=5 os_prio=0 cpu=16608.47ms elapsed=967959.31s tid=0x0000ffff855fb000 nid=0x233 runnable [0x0000fffa7ddfe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c66d10a0> (a sun.nio.ch.Util$2) - locked <0x00000005c66d0f50> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at kafka.common.InterBrokerSendThread.doWork(InterBrokerSendThread.scala:66) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "OkHttp ConnectionPool" #103 daemon prio=5 os_prio=0 cpu=428.63ms elapsed=967959.14s tid=0x0000ffff8568b000 nid=0x234 in Object.wait() [0x0000fffa7d9fe000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.14/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.14/Object.java:462) at okhttp3.internal.connection.RealConnectionPool.lambda$new$0(RealConnectionPool.java:62) - waiting to re-lock in wait() <0x00000005c66e1a88> (a okhttp3.internal.connection.RealConnectionPool) at okhttp3.internal.connection.RealConnectionPool$$Lambda$803/0x00000008006f7040.run(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "FetchAppResourcesScheduledThread" #105 prio=5 os_prio=0 cpu=7967.32ms elapsed=967959.11s tid=0x0000ffff85694800 nid=0x236 waiting on condition [0x0000fffa7adfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66e6658> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "ExpirationReaper-7-AlterAcls" #106 prio=5 os_prio=0 cpu=62735.98ms elapsed=967959.09s tid=0x0000ffff8574d000 nid=0x237 waiting on condition [0x0000fffa7abfe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66dd1e0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.14/DelayQueue.java:265) at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105) at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:438) at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:464) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "data-plane-kafka-request-handler-0" #107 daemon prio=5 os_prio=0 cpu=171260320.88ms elapsed=967959.09s tid=0x0000ffff85728000 nid=0x238 waiting on condition [0x0000fffa7a9fd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.readRecords(Partition.scala:982) at kafka.server.ReplicaManager.read$1(ReplicaManager.scala:1008) at kafka.server.ReplicaManager.$anonfun$readFromLocalLog$8(ReplicaManager.scala:1080) at kafka.server.ReplicaManager$$Lambda$1333/0x00000008008bd840.apply(Unknown Source) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at kafka.server.ReplicaManager.readFromLocalLog(ReplicaManager.scala:1079) at kafka.server.ReplicaManager.readFromLog$1(ReplicaManager.scala:893) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:898) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:809) at kafka.server.KafkaApis.handle(KafkaApis.scala:127) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-1" #108 daemon prio=5 os_prio=0 cpu=171115960.07ms elapsed=967959.09s tid=0x0000ffff85729800 nid=0x239 waiting on condition [0x0000fffa7a7fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-2" #109 daemon prio=5 os_prio=0 cpu=170932966.75ms elapsed=967959.09s tid=0x0000ffff8572f000 nid=0x23a waiting on condition [0x0000fffa7a5fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-3" #110 daemon prio=5 os_prio=0 cpu=170956257.36ms elapsed=967959.09s tid=0x0000ffff85731000 nid=0x23b waiting on condition [0x0000fffa7a3fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.legacyFetchOffsetsForTimestamp(Partition.scala:1058) at kafka.server.ReplicaManager.legacyFetchOffsetsForTimestamp(ReplicaManager.scala:855) at kafka.server.KafkaApis.$anonfun$handleListOffsetRequestV0$4(KafkaApis.scala:884) at kafka.server.KafkaApis$$Lambda$1451/0x0000000800914840.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.KafkaApis.handleListOffsetRequestV0(KafkaApis.scala:877) at kafka.server.KafkaApis.handleListOffsetRequest(KafkaApis.scala:856) at kafka.server.KafkaApis.handle(KafkaApis.scala:128) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-4" #111 daemon prio=5 os_prio=0 cpu=171132686.43ms elapsed=967959.08s tid=0x0000ffff85734000 nid=0x23c waiting on condition [0x0000fffa7a1fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-5" #112 daemon prio=5 os_prio=0 cpu=170790882.25ms elapsed=967959.08s tid=0x0000ffff85736000 nid=0x23d waiting on condition [0x0000fffa79ffe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-6" #113 daemon prio=5 os_prio=0 cpu=171147685.34ms elapsed=967959.08s tid=0x0000ffff85738000 nid=0x23e waiting on condition [0x0000fffa79dfd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.fetchOffsetForTimestamp(Partition.scala:1005) at kafka.server.ReplicaManager.fetchOffsetForTimestamp(ReplicaManager.scala:846) at kafka.server.KafkaApis.$anonfun$handleListOffsetRequestV1AndAbove$4(KafkaApis.scala:950) at kafka.server.KafkaApis$$Lambda$1222/0x0000000800853840.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.KafkaApis.handleListOffsetRequestV1AndAbove(KafkaApis.scala:920) at kafka.server.KafkaApis.handleListOffsetRequest(KafkaApis.scala:858) at kafka.server.KafkaApis.handle(KafkaApis.scala:128) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-7" #114 daemon prio=5 os_prio=0 cpu=171198893.28ms elapsed=967959.08s tid=0x0000ffff8573a000 nid=0x23f waiting on condition [0x0000fffa723fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-8" #115 daemon prio=5 os_prio=0 cpu=171306474.00ms elapsed=967959.09s tid=0x0000ffff8573c800 nid=0x240 waiting on condition [0x0000fffa721fd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.fetchOffsetForTimestamp(Partition.scala:1005) at kafka.server.ReplicaManager.fetchOffsetForTimestamp(ReplicaManager.scala:846) at kafka.server.KafkaApis.$anonfun$handleListOffsetRequestV1AndAbove$4(KafkaApis.scala:950) at kafka.server.KafkaApis$$Lambda$1222/0x0000000800853840.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.KafkaApis.handleListOffsetRequestV1AndAbove(KafkaApis.scala:920) at kafka.server.KafkaApis.handleListOffsetRequest(KafkaApis.scala:858) at kafka.server.KafkaApis.handle(KafkaApis.scala:128) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-9" #116 daemon prio=5 os_prio=0 cpu=170746813.61ms elapsed=967959.09s tid=0x0000ffff8573e800 nid=0x241 waiting on condition [0x0000fffa71ffe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-10" #117 daemon prio=5 os_prio=0 cpu=171553563.35ms elapsed=967959.09s tid=0x0000ffff85740000 nid=0x242 waiting on condition [0x0000fffa71dfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.legacyFetchOffsetsForTimestamp(Partition.scala:1058) at kafka.server.ReplicaManager.legacyFetchOffsetsForTimestamp(ReplicaManager.scala:855) at kafka.server.KafkaApis.$anonfun$handleListOffsetRequestV0$4(KafkaApis.scala:884) at kafka.server.KafkaApis$$Lambda$1451/0x0000000800914840.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.KafkaApis.handleListOffsetRequestV0(KafkaApis.scala:877) at kafka.server.KafkaApis.handleListOffsetRequest(KafkaApis.scala:856) at kafka.server.KafkaApis.handle(KafkaApis.scala:128) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-11" #118 daemon prio=5 os_prio=0 cpu=172230046.00ms elapsed=967959.09s tid=0x0000ffff85742000 nid=0x243 runnable [0x0000fffa71bfd000] java.lang.Thread.State: RUNNABLE at kafka.log.AbstractIndex.binarySearch$1(AbstractIndex.scala:379) at kafka.log.AbstractIndex.indexSlotRangeFor(AbstractIndex.scala:396) at kafka.log.AbstractIndex.largestLowerBoundSlotFor(AbstractIndex.scala:359) at kafka.log.OffsetIndex.$anonfun$lookup$1(OffsetIndex.scala:91) at kafka.log.OffsetIndex$$Lambda$400/0x00000008004ac840.apply(Unknown Source) at kafka.log.AbstractIndex.maybeLock(AbstractIndex.scala:334) at kafka.log.OffsetIndex.lookup(OffsetIndex.scala:89) at kafka.log.LogSegment.translateOffset(LogSegment.scala:274) at kafka.log.LogSegment.read(LogSegment.scala:298) at kafka.log.Log.$anonfun$read$2(Log.scala:1495) at kafka.log.Log$$Lambda$455/0x00000008004e9c40.apply(Unknown Source) at kafka.log.Log.maybeHandleIOException(Log.scala:2316) at kafka.log.Log.read(Log.scala:1450) at kafka.cluster.Partition.$anonfun$readRecords$1(Partition.scala:992) at kafka.cluster.Partition$$Lambda$1340/0x00000008008c4840.apply(Unknown Source) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:253) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.readRecords(Partition.scala:982) at kafka.server.ReplicaManager.read$1(ReplicaManager.scala:1008) at kafka.server.ReplicaManager.$anonfun$readFromLocalLog$8(ReplicaManager.scala:1080) at kafka.server.ReplicaManager$$Lambda$1333/0x00000008008bd840.apply(Unknown Source) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at kafka.server.ReplicaManager.readFromLocalLog(ReplicaManager.scala:1079) at kafka.server.ReplicaManager.readFromLog$1(ReplicaManager.scala:893) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:898) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:809) at kafka.server.KafkaApis.handle(KafkaApis.scala:127) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-12" #119 daemon prio=5 os_prio=0 cpu=171227196.92ms elapsed=967959.09s tid=0x0000ffff85744000 nid=0x244 waiting on condition [0x0000fffa719fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-13" #120 daemon prio=5 os_prio=0 cpu=171006321.92ms elapsed=967959.09s tid=0x0000ffff85746000 nid=0x245 waiting on condition [0x0000fffa717fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-14" #121 daemon prio=5 os_prio=0 cpu=171073926.69ms elapsed=967959.09s tid=0x0000ffff85748800 nid=0x246 waiting on condition [0x0000fffa715fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-15" #122 daemon prio=5 os_prio=0 cpu=170899852.73ms elapsed=967959.08s tid=0x0000ffff8574a800 nid=0x247 waiting on condition [0x0000fffa713fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-16" #123 daemon prio=5 os_prio=0 cpu=170978560.32ms elapsed=967959.08s tid=0x0000ffff8569e800 nid=0x248 waiting on condition [0x0000fffa711fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-17" #124 daemon prio=5 os_prio=0 cpu=171259513.67ms elapsed=967959.08s tid=0x0000ffff856a0000 nid=0x249 waiting on condition [0x0000fffa683fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-18" #125 daemon prio=5 os_prio=0 cpu=171186639.89ms elapsed=967959.08s tid=0x0000ffff856a2800 nid=0x24a waiting on condition [0x0000fffa681fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-19" #126 daemon prio=5 os_prio=0 cpu=171070196.99ms elapsed=967959.08s tid=0x0000ffff856a4000 nid=0x24b waiting on condition [0x0000fffa67ffe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-20" #127 daemon prio=5 os_prio=0 cpu=171265734.43ms elapsed=967959.08s tid=0x0000ffff856a6800 nid=0x24c waiting on condition [0x0000fffa67dfd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.readRecords(Partition.scala:982) at kafka.server.ReplicaManager.read$1(ReplicaManager.scala:1008) at kafka.server.ReplicaManager.$anonfun$readFromLocalLog$8(ReplicaManager.scala:1080) at kafka.server.ReplicaManager$$Lambda$1333/0x00000008008bd840.apply(Unknown Source) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at kafka.server.ReplicaManager.readFromLocalLog(ReplicaManager.scala:1079) at kafka.server.ReplicaManager.readFromLog$1(ReplicaManager.scala:893) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:898) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:809) at kafka.server.KafkaApis.handle(KafkaApis.scala:127) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-21" #128 daemon prio=5 os_prio=0 cpu=170960949.45ms elapsed=967959.08s tid=0x0000ffff856a8800 nid=0x24d waiting on condition [0x0000fffa67bfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-22" #129 daemon prio=5 os_prio=0 cpu=170955038.41ms elapsed=967959.08s tid=0x0000ffff856aa800 nid=0x24e waiting on condition [0x0000fffa679fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.appendRecordsToLeader(Partition.scala:943) at kafka.server.ReplicaManager.$anonfun$appendToLocalLog$4(ReplicaManager.scala:805) at kafka.server.ReplicaManager$$Lambda$1525/0x00000008008cb040.apply(Unknown Source) at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:238) at scala.collection.TraversableLike$$Lambda$116/0x0000000800228040.apply(Unknown Source) at scala.collection.mutable.HashMap.$anonfun$foreach$1(HashMap.scala:149) at scala.collection.mutable.HashMap$$Lambda$128/0x0000000800268840.apply(Unknown Source) at scala.collection.mutable.HashTable.foreachEntry(HashTable.scala:237) at scala.collection.mutable.HashTable.foreachEntry$(HashTable.scala:230) at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:44) at scala.collection.mutable.HashMap.foreach(HashMap.scala:149) at scala.collection.TraversableLike.map(TraversableLike.scala:238) at scala.collection.TraversableLike.map$(TraversableLike.scala:231) at scala.collection.AbstractTraversable.map(Traversable.scala:108) at kafka.server.ReplicaManager.appendToLocalLog(ReplicaManager.scala:793) at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:517) at kafka.server.KafkaApis.handleProduceRequest(KafkaApis.scala:577) at kafka.server.KafkaApis.handle(KafkaApis.scala:126) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-request-handler-23" #130 daemon prio=5 os_prio=0 cpu=171003639.58ms elapsed=967959.08s tid=0x0000ffff856ac800 nid=0x24f waiting on condition [0x0000fffa677fd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6bc21d0> (a java.util.concurrent.locks.ReentrantReadWriteLock$NonfairSync) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(java.base@11.0.14/AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1009) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireShared(java.base@11.0.14/AbstractQueuedSynchronizer.java:1324) at java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock.lock(java.base@11.0.14/ReentrantReadWriteLock.java:738) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251) at kafka.utils.CoreUtils$.inReadLock(CoreUtils.scala:259) at kafka.cluster.Partition.readRecords(Partition.scala:982) at kafka.server.ReplicaManager.read$1(ReplicaManager.scala:1008) at kafka.server.ReplicaManager.$anonfun$readFromLocalLog$8(ReplicaManager.scala:1080) at kafka.server.ReplicaManager$$Lambda$1333/0x00000008008bd840.apply(Unknown Source) at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62) at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49) at kafka.server.ReplicaManager.readFromLocalLog(ReplicaManager.scala:1079) at kafka.server.ReplicaManager.readFromLog$1(ReplicaManager.scala:893) at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:898) at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:809) at kafka.server.KafkaApis.handle(KafkaApis.scala:127) at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:70) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "trace_metric-0" #131 prio=5 os_prio=0 cpu=2012.96ms elapsed=967959.07s tid=0x0000ffff856bf000 nid=0x250 waiting on condition [0x0000fffa675fe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66cfee0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "/config/changes-event-process-thread" #132 prio=5 os_prio=0 cpu=15.65ms elapsed=967959.07s tid=0x0000ffff856c9800 nid=0x251 waiting on condition [0x0000fffa673fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66d8378> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread.doWork(ZkNodeChangeNotificationListener.scala:146) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "data-plane-kafka-network-thread-7-ListenerName(PLAINTEXT)-PLAINTEXT-0" #133 prio=5 os_prio=0 cpu=74300336.40ms elapsed=967958.62s tid=0x0000ffff856d4000 nid=0x252 waiting on condition [0x0000fffa671fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(PLAINTEXT)-PLAINTEXT-1" #134 prio=5 os_prio=0 cpu=59197294.50ms elapsed=967958.62s tid=0x0000ffff856d6000 nid=0x253 waiting on condition [0x0000fffa5f7fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(PLAINTEXT)-PLAINTEXT-2" #135 prio=5 os_prio=0 cpu=140750761.14ms elapsed=967958.62s tid=0x0000ffff856d8000 nid=0x254 waiting on condition [0x0000fffa5f5fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(PLAINTEXT)-PLAINTEXT-3" #136 prio=5 os_prio=0 cpu=204125203.83ms elapsed=967958.62s tid=0x0000ffff856da000 nid=0x255 waiting on condition [0x0000fffa5f3fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-4" #137 prio=5 os_prio=0 cpu=393264254.80ms elapsed=967958.62s tid=0x0000ffff856dc000 nid=0x256 waiting on condition [0x0000fffa5f1fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-5" #138 prio=5 os_prio=0 cpu=500634360.60ms elapsed=967958.62s tid=0x0000ffff856de000 nid=0x257 waiting on condition [0x0000fffa5effe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-6" #139 prio=5 os_prio=0 cpu=387767856.07ms elapsed=967958.62s tid=0x0000ffff856e0000 nid=0x258 waiting on condition [0x0000fffa5edfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "data-plane-kafka-network-thread-7-ListenerName(SASL_PLAINTEXT)-SASL_PLAINTEXT-7" #140 prio=5 os_prio=0 cpu=332918650.72ms elapsed=967958.62s tid=0x0000ffff856e2000 nid=0x259 waiting on condition [0x0000fffa5ebfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000006335588b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.ArrayBlockingQueue.put(java.base@11.0.14/ArrayBlockingQueue.java:367) at kafka.network.RequestChannel.sendRequest(RequestChannel.scala:312) at kafka.network.Processor.$anonfun$processCompletedReceives$1(SocketServer.scala:920) at kafka.network.Processor.$anonfun$processCompletedReceives$1$adapted(SocketServer.scala:900) at kafka.network.Processor$$Lambda$870/0x0000000800747040.apply(Unknown Source) at scala.collection.Iterator.foreach(Iterator.scala:941) at scala.collection.Iterator.foreach$(Iterator.scala:941) at scala.collection.AbstractIterator.foreach(Iterator.scala:1429) at scala.collection.IterableLike.foreach(IterableLike.scala:74) at scala.collection.IterableLike.foreach$(IterableLike.scala:73) at scala.collection.AbstractIterable.foreach(Iterable.scala:56) at kafka.network.Processor.processCompletedReceives(SocketServer.scala:900) at kafka.network.Processor.run(SocketServer.scala:790) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "ReplicaFetcherThread-1-5" #142 prio=5 os_prio=0 cpu=6855382.61ms elapsed=967957.12s tid=0x0000fff86470c000 nid=0x25b runnable [0x0000fffa5e5fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c675cda8> (a sun.nio.ch.Util$2) - locked <0x00000005c675cd50> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-0-5" #143 prio=5 os_prio=0 cpu=213315.61ms elapsed=967957.12s tid=0x0000fff864712000 nid=0x25c runnable [0x0000fffa557fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c6765418> (a sun.nio.ch.Util$2) - locked <0x00000005c67653c0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-0-9" #144 prio=5 os_prio=0 cpu=198641948.65ms elapsed=967957.11s tid=0x0000fff864717800 nid=0x25d runnable [0x0000fffa555fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c68799e8> (a sun.nio.ch.Util$2) - locked <0x00000005c685c680> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-1-6" #145 prio=5 os_prio=0 cpu=7305045.36ms elapsed=967957.11s tid=0x0000fff86471d800 nid=0x25e runnable [0x0000fffa551fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c67c6848> (a sun.nio.ch.Util$2) - locked <0x00000005c67c67f0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-0-6" #146 prio=5 os_prio=0 cpu=245876.80ms elapsed=967957.11s tid=0x0000fff864723800 nid=0x25f runnable [0x0000fffa54ffe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c6863aa0> (a sun.nio.ch.Util$2) - locked <0x00000005c6863a48> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-1-9" #149 prio=5 os_prio=0 cpu=170606528.02ms elapsed=967957.10s tid=0x0000fff864736000 nid=0x262 runnable [0x0000fffa549fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x00000005c69056a0> (a sun.nio.ch.Util$2) - locked <0x00000005c6905648> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "RMI Scheduler(0)" #151 daemon prio=5 os_prio=0 cpu=1179.64ms elapsed=967943.59s tid=0x0000fffe400e7000 nid=0x267 waiting on condition [0x0000fffd61a3d000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x0000000580a9a450> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.14/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.14/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:1182) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.14/ScheduledThreadPoolExecutor.java:899) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "executor-Fetch" #156 prio=5 os_prio=0 cpu=12682523.50ms elapsed=967939.58s tid=0x0000fff8c8001000 nid=0x26d waiting on condition [0x0000fffd34dfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c66daf08> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "executor-Rebalance" #225 prio=5 os_prio=0 cpu=355.50ms elapsed=966717.56s tid=0x0000fff8a8008800 nid=0x2c5 waiting on condition [0x0000fffbbcdfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6941070> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "executor-Heartbeat" #18153 prio=5 os_prio=0 cpu=18.47ms elapsed=647966.33s tid=0x0000fff8a4003000 nid=0x5b0b waiting on condition [0x0000fffd34bfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x000000063348b808> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "executor-Produce" #19006 prio=5 os_prio=0 cpu=21.43ms elapsed=632765.98s tid=0x0000fff8c4006000 nid=0x5f48 waiting on condition [0x0000fffa7affe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.14/Native Method) - parking to wait for <0x00000005c6a78220> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.14/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.14/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.14/LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.14/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "ReplicaFetcherThread-0-8" #44317 prio=5 os_prio=0 cpu=33606920.07ms elapsed=181462.23s tid=0x0000fff87803c800 nid=0x5d24 runnable [0x0000fffa5e7fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x000000061e19f130> (a sun.nio.ch.Util$2) - locked <0x000000061e19f0d8> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "ReplicaFetcherThread-1-8" #44318 prio=5 os_prio=0 cpu=31328724.98ms elapsed=181462.22s tid=0x0000fff878017000 nid=0x5d25 runnable [0x0000fffa54dfe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.14/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.14/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.14/SelectorImpl.java:124) - locked <0x000000061e1a38d8> (a sun.nio.ch.Util$2) - locked <0x000000061e1a3880> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.14/SelectorImpl.java:136) at org.apache.kafka.common.network.Selector.select(Selector.java:794) at org.apache.kafka.common.network.Selector.poll(Selector.java:467) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:540) at org.apache.kafka.clients.NetworkClientUtils.sendAndReceive(NetworkClientUtils.java:96) at kafka.server.ReplicaFetcherBlockingSend.sendRequest(ReplicaFetcherBlockingSend.scala:107) at kafka.server.ReplicaFetcherThread.fetchFromLeader(ReplicaFetcherThread.scala:196) at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:286) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3(AbstractFetcherThread.scala:133) at kafka.server.AbstractFetcherThread.$anonfun$maybeFetch$3$adapted(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread$$Lambda$966/0x00000008007a4840.apply(Unknown Source) at scala.Option.foreach(Option.scala:407) at kafka.server.AbstractFetcherThread.maybeFetch(AbstractFetcherThread.scala:132) at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:114) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96) "RMI TCP Connection(67163)-172.16.228.243" #53738 daemon prio=5 os_prio=0 cpu=18428.81ms elapsed=13220.41s tid=0x0000ffff04008000 nid=0xd02 runnable [0x0000fffda1f25000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.14/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.14/SocketInputStream.java:115) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:168) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:140) at java.io.BufferedInputStream.fill(java.base@11.0.14/BufferedInputStream.java:252) at java.io.BufferedInputStream.read(java.base@11.0.14/BufferedInputStream.java:271) - locked <0x00000005a28eea58> (a java.io.BufferedInputStream) at java.io.FilterInputStream.read(java.base@11.0.14/FilterInputStream.java:83) at sun.rmi.transport.tcp.TCPTransport.handleMessages(java.rmi@11.0.14/TCPTransport.java:544) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(java.rmi@11.0.14/TCPTransport.java:796) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(java.rmi@11.0.14/TCPTransport.java:677) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler$$Lambda$1302/0x0000000800886c40.run(java.rmi@11.0.14/Unknown Source) at java.security.AccessController.doPrivileged(java.base@11.0.14/Native Method) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(java.rmi@11.0.14/TCPTransport.java:676) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "RMI TCP Connection(67166)-172.16.228.243" #54378 daemon prio=5 os_prio=0 cpu=1760.53ms elapsed=1642.10s tid=0x0000ffff04004800 nid=0x1038 runnable [0x0000fffd34ffd000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.14/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.14/SocketInputStream.java:115) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:168) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:140) at java.io.BufferedInputStream.fill(java.base@11.0.14/BufferedInputStream.java:252) at java.io.BufferedInputStream.read(java.base@11.0.14/BufferedInputStream.java:271) - locked <0x00000005a28f7670> (a java.io.BufferedInputStream) at java.io.FilterInputStream.read(java.base@11.0.14/FilterInputStream.java:83) at sun.rmi.transport.tcp.TCPTransport.handleMessages(java.rmi@11.0.14/TCPTransport.java:544) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(java.rmi@11.0.14/TCPTransport.java:796) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(java.rmi@11.0.14/TCPTransport.java:677) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler$$Lambda$1302/0x0000000800886c40.run(java.rmi@11.0.14/Unknown Source) at java.security.AccessController.doPrivileged(java.base@11.0.14/Native Method) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(java.rmi@11.0.14/TCPTransport.java:676) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "RMI TCP Connection(67168)-172.16.228.243" #54455 daemon prio=5 os_prio=0 cpu=290.67ms elapsed=322.75s tid=0x0000ffff04009800 nid=0x1085 runnable [0x0000fffa54bfd000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.14/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.14/SocketInputStream.java:115) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:168) at java.net.SocketInputStream.read(java.base@11.0.14/SocketInputStream.java:140) at java.io.BufferedInputStream.fill(java.base@11.0.14/BufferedInputStream.java:252) at java.io.BufferedInputStream.read(java.base@11.0.14/BufferedInputStream.java:271) - locked <0x00000005a2910260> (a java.io.BufferedInputStream) at java.io.FilterInputStream.read(java.base@11.0.14/FilterInputStream.java:83) at sun.rmi.transport.tcp.TCPTransport.handleMessages(java.rmi@11.0.14/TCPTransport.java:544) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run0(java.rmi@11.0.14/TCPTransport.java:796) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.lambda$run$0(java.rmi@11.0.14/TCPTransport.java:677) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler$$Lambda$1302/0x0000000800886c40.run(java.rmi@11.0.14/Unknown Source) at java.security.AccessController.doPrivileged(java.base@11.0.14/Native Method) at sun.rmi.transport.tcp.TCPTransport$ConnectionHandler.run(java.rmi@11.0.14/TCPTransport.java:676) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.14/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.14/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.14/Thread.java:829) "VM Thread" os_prio=0 cpu=245955.11ms elapsed=968483.05s tid=0x0000ffff846d0800 nid=0x196 runnable "GC Thread#0" os_prio=0 cpu=2802286.14ms elapsed=968483.09s tid=0x0000ffff84041800 nid=0x191 runnable "GC Thread#1" os_prio=0 cpu=2800690.02ms elapsed=968479.50s tid=0x0000ffff34001000 nid=0x1e4 runnable "GC Thread#2" os_prio=0 cpu=2802168.57ms elapsed=968479.50s tid=0x0000ffff34002000 nid=0x1e5 runnable "GC Thread#3" os_prio=0 cpu=2800187.80ms elapsed=968479.50s tid=0x0000ffff34003000 nid=0x1e6 runnable "GC Thread#4" os_prio=0 cpu=2801705.36ms elapsed=968479.50s tid=0x0000ffff34004000 nid=0x1e7 runnable "GC Thread#5" os_prio=0 cpu=2801970.55ms elapsed=968479.50s tid=0x0000ffff34005000 nid=0x1e8 runnable "GC Thread#6" os_prio=0 cpu=2802494.47ms elapsed=968479.50s tid=0x0000ffff34006800 nid=0x1e9 runnable "GC Thread#7" os_prio=0 cpu=2801961.77ms elapsed=968479.50s tid=0x0000ffff34008800 nid=0x1ea runnable "GC Thread#8" os_prio=0 cpu=2802560.07ms elapsed=968479.50s tid=0x0000ffff3400a000 nid=0x1eb runnable "GC Thread#9" os_prio=0 cpu=2800649.72ms elapsed=968479.50s tid=0x0000ffff3400b800 nid=0x1ec runnable "GC Thread#10" os_prio=0 cpu=2800980.68ms elapsed=968479.50s tid=0x0000ffff3400d000 nid=0x1ed runnable "GC Thread#11" os_prio=0 cpu=2801792.72ms elapsed=968479.50s tid=0x0000ffff3400e800 nid=0x1ee runnable "GC Thread#12" os_prio=0 cpu=2801222.58ms elapsed=968479.50s tid=0x0000ffff34010000 nid=0x1ef runnable "G1 Main Marker" os_prio=0 cpu=906.39ms elapsed=968483.09s tid=0x0000ffff84052000 nid=0x192 runnable "G1 Conc#0" os_prio=0 cpu=46443.96ms elapsed=968483.09s tid=0x0000ffff84054000 nid=0x193 runnable "G1 Conc#1" os_prio=0 cpu=46227.94ms elapsed=967949.81s tid=0x0000ffff48001000 nid=0x264 runnable "G1 Conc#2" os_prio=0 cpu=46367.62ms elapsed=967949.80s tid=0x0000ffff48002800 nid=0x265 runnable "G1 Refine#0" os_prio=0 cpu=1011833.23ms elapsed=968483.08s tid=0x0000ffff8466d000 nid=0x194 runnable "G1 Refine#1" os_prio=0 cpu=193321.75ms elapsed=967183.28s tid=0x0000ffff44003800 nid=0x2a9 runnable "G1 Refine#2" os_prio=0 cpu=34974.72ms elapsed=965657.77s tid=0x0000fff88c1b6800 nid=0x320 runnable "G1 Refine#3" os_prio=0 cpu=2952.15ms elapsed=964329.24s tid=0x0000fffe40183000 nid=0x38a runnable "G1 Refine#4" os_prio=0 cpu=111.49ms elapsed=344346.60s tid=0x0000fff89c042000 nid=0x3042 runnable "G1 Refine#5" os_prio=0 cpu=2.81ms elapsed=252119.36s tid=0x0000fff908003000 nid=0x49a5 runnable "G1 Young RemSet Sampling" os_prio=0 cpu=268376.99ms elapsed=968483.08s tid=0x0000ffff8466e800 nid=0x195 runnable "VM Periodic Task Thread" os_prio=0 cpu=262202.09ms elapsed=968482.34s tid=0x0000ffff84ddc800 nid=0x1a5 waiting on condition JNI global refs: 33, weak refs: 0