"main" prio=5 tid=1 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1039) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#2 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#3 at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1345) local variable: java.util.concurrent.CountDownLatch$Sync#2 at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:232) local variable: java.util.concurrent.CountDownLatch#2 at org.apache.kafka.connect.runtime.Connect.awaitStop(Connect.java:80) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:81) local variable: java.lang.String[]#64 local variable: java.lang.String#5497 local variable: java.util.HashMap#1047 local variable: org.apache.kafka.connect.cli.ConnectDistributed#1 local variable: org.apache.kafka.connect.runtime.WorkerInfo#1 local variable: org.apache.kafka.connect.runtime.Connect#1 "Signal Dispatcher" daemon prio=9 tid=4 RUNNABLE "Reference Handler" daemon prio=10 tid=2 RUNNABLE at java.lang.ref.Reference.waitForReferencePendingList(Native Method) at java.lang.ref.Reference.processPendingReferences(Reference.java:241) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:213) "Finalizer" daemon prio=8 tid=3 WAITING at java.lang.Object.wait(Native Method) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) local variable: java.lang.ref.ReferenceQueue$Lock#58 at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:176) local variable: java.lang.ref.ReferenceQueue#58 at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:170) local variable: java.lang.System$2#1 "Common-Cleaner" daemon prio=8 tid=8 TIMED_WAITING at java.lang.Object.wait(Native Method) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) local variable: java.lang.ref.ReferenceQueue$Lock#78 local variable: java.lang.ref.ReferenceQueue#77 at jdk.internal.ref.CleanerImpl.run(CleanerImpl.java:148) local variable: jdk.internal.ref.CleanerImpl#1 at java.lang.Thread.run(Thread.java:834) at jdk.internal.misc.InnocuousThread.run(InnocuousThread.java:134) "server-timer" daemon prio=5 tid=11 TIMED_WAITING at java.lang.Object.wait(Native Method) at java.util.TimerThread.mainLoop(Timer.java:553) local variable: java.util.TaskQueue#1 local variable: sun.net.httpserver.ServerImpl$ServerTimerTask#1 local variable: java.lang.Object#135 at java.util.TimerThread.run(Timer.java:506) "JolokiaDiscoveryListenerThread-[REDACTED]" daemon prio=5 tid=12 RUNNABLE at java.net.PlainDatagramSocketImpl.receive0(Native Method) at java.net.AbstractPlainDatagramSocketImpl.receive(AbstractPlainDatagramSocketImpl.java:181) local variable: java.net.PlainDatagramSocketImpl#1 at java.net.DatagramSocket.receive(DatagramSocket.java:814) local variable: java.net.MulticastSocket#1 at org.jolokia.discovery.MulticastSocketListenerThread.receiveMessage(MulticastSocketListenerThread.java:115) local variable: byte[]#6310 local variable: java.net.DatagramPacket#1 at org.jolokia.discovery.MulticastSocketListenerThread.run(MulticastSocketListenerThread.java:72) "Jolokia Agent Cleanup Thread" daemon prio=5 tid=14 WAITING at java.lang.Object.wait(Native Method) at java.lang.Thread.join(Thread.java:1305) at java.lang.Thread.join(Thread.java:1380) at org.jolokia.jvmagent.CleanupThread.joinThreads(CleanupThread.java:110) at org.jolokia.jvmagent.CleanupThread.run(CleanupThread.java:60) local variable: java.lang.Thread[]#2 "HTTP-Dispatcher" daemon prio=5 tid=15 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#1 local variable: sun.nio.ch.Util$2#1 at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:136) at sun.net.httpserver.ServerImpl$Dispatcher.run(ServerImpl.java:365) local variable: sun.net.httpserver.ServerImpl$Dispatcher#1 local variable: java.util.LinkedList$ListItr#1 at java.lang.Thread.run(Thread.java:834) "RMI TCP Accept-0" daemon prio=5 tid=17 RUNNABLE at java.net.PlainSocketImpl.socketAccept(Native Method) at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:458) local variable: java.net.SocksSocketImpl#1 at java.net.ServerSocket.implAccept(ServerSocket.java:565) local variable: java.net.SocksSocketImpl#2 at java.net.ServerSocket.accept(ServerSocket.java:533) local variable: java.net.Socket#1 at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52) local variable: sun.management.jmxremote.LocalRMIServerSocketFactory$1#1 at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:394) at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:366) local variable: sun.rmi.transport.tcp.TCPTransport$AcceptLoop#1 at java.lang.Thread.run(Thread.java:834) "qtp640275932-56" prio=5 tid=56 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#10 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#17 at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:382) local variable: org.eclipse.jetty.util.BlockingArrayQueue#1 at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.idleJobPoll(QueuedThreadPool.java:851) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:890) at java.lang.Thread.run(Thread.java:834) "qtp640275932-53" prio=5 tid=53 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#30 at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:382) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.idleJobPoll(QueuedThreadPool.java:851) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:890) at java.lang.Thread.run(Thread.java:834) "qtp640275932-54" prio=5 tid=54 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.Util$2#11 at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:141) at org.eclipse.jetty.io.ManagedSelector$SelectorProducer.select(ManagedSelector.java:466) local variable: sun.nio.ch.EPollSelectorImpl#11 at org.eclipse.jetty.io.ManagedSelector$SelectorProducer.produce(ManagedSelector.java:403) local variable: org.eclipse.jetty.io.ManagedSelector$SelectorProducer#1 at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.produceTask(EatWhatYouKill.java:360) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:184) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129) at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367) local variable: org.eclipse.jetty.util.thread.strategy.EatWhatYouKill#1 at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918) local variable: org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread#2 at java.lang.Thread.run(Thread.java:834) "qtp640275932-55" prio=5 tid=55 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#26 at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:382) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.idleJobPoll(QueuedThreadPool.java:851) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:890) at java.lang.Thread.run(Thread.java:834) "qtp640275932-51" prio=5 tid=51 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#25 at org.eclipse.jetty.util.BlockingArrayQueue.poll(BlockingArrayQueue.java:382) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.idleJobPoll(QueuedThreadPool.java:851) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:890) at java.lang.Thread.run(Thread.java:834) "qtp640275932-57" prio=5 tid=57 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2211) local variable: java.util.concurrent.TimeUnit#5 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#59 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#28 at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.reservedWait(ReservedThreadExecutor.java:293) local variable: org.eclipse.jetty.util.thread.Locker$Lock#5 at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:358) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782) local variable: org.eclipse.jetty.util.thread.QueuedThreadPool#1 at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918) local variable: org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread#3 local variable: org.eclipse.jetty.util.thread.QueuedThreadPool$Runner#1 at java.lang.Thread.run(Thread.java:834) "qtp640275932-50" prio=5 tid=50 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2211) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#57 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#24 at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.reservedWait(ReservedThreadExecutor.java:293) local variable: org.eclipse.jetty.util.thread.Locker$Lock#3 at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:358) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918) local variable: org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread#1 at java.lang.Thread.run(Thread.java:834) "KafkaBasedLog Work Thread - __connect_configs" prio=5 tid=69 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#8 local variable: sun.nio.ch.Util$2#8 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#7 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#7 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) local variable: org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient#4 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300) local variable: org.apache.kafka.common.utils.Timer#17 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1240) local variable: org.apache.kafka.common.utils.Timer#1 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211) local variable: java.time.Duration#1 local variable: org.apache.kafka.clients.consumer.KafkaConsumer#3 at org.apache.kafka.connect.util.KafkaBasedLog.poll(KafkaBasedLog.java:267) at org.apache.kafka.connect.util.KafkaBasedLog.access$500(KafkaBasedLog.java:71) at org.apache.kafka.connect.util.KafkaBasedLog$WorkThread.run(KafkaBasedLog.java:348) local variable: org.apache.kafka.connect.util.KafkaBasedLog#3 "kafka-producer-network-thread | producer-3" daemon prio=5 tid=68 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#2 local variable: sun.nio.ch.Util$2#2 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#1 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#1 at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) local variable: org.apache.kafka.clients.producer.internals.Sender#1 at java.lang.Thread.run(Thread.java:834) "kafka-producer-network-thread | producer-1" daemon prio=5 tid=61 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.Util$2#3 local variable: sun.nio.ch.EPollSelectorImpl#3 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#2 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#2 at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) local variable: org.apache.kafka.clients.producer.internals.Sender#2 at java.lang.Thread.run(Thread.java:834) "Session-HouseKeeper-18b6d3c1" prio=5 tid=62 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#21 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#18 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1182) local variable: java.util.concurrent.locks.ReentrantLock#25 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:899) local variable: java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue#2 at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) local variable: java.util.concurrent.ScheduledThreadPoolExecutor#2 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#2 at java.lang.Thread.run(Thread.java:834) "KafkaBasedLog Work Thread - __connect_offsets" prio=5 tid=63 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#4 local variable: sun.nio.ch.Util$2#4 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#3 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#3 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) local variable: org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient#1 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300) local variable: org.apache.kafka.common.utils.Timer#18 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1240) local variable: org.apache.kafka.clients.consumer.KafkaConsumer#1 local variable: org.apache.kafka.common.utils.Timer#14 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211) at org.apache.kafka.connect.util.KafkaBasedLog.poll(KafkaBasedLog.java:267) at org.apache.kafka.connect.util.KafkaBasedLog.access$500(KafkaBasedLog.java:71) at org.apache.kafka.connect.util.KafkaBasedLog$WorkThread.run(KafkaBasedLog.java:348) local variable: org.apache.kafka.connect.util.KafkaBasedLog#1 "kafka-coordinator-heartbeat-thread | connect" daemon prio=5 tid=70 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:885) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:917) local variable: java.util.concurrent.locks.ReentrantLock$FairSync#2 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#32 at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1240) at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:267) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:246) local variable: org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient#2 local variable: org.apache.kafka.common.utils.Timer#19 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup(ConsumerNetworkClient.java:303) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1210) local variable: org.apache.kafka.connect.runtime.distributed.WorkerCoordinator#1 "mysql-cj-abandoned-connection-cleanup" daemon prio=5 tid=20 TIMED_WAITING at java.lang.Object.wait(Native Method) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) local variable: java.lang.ref.ReferenceQueue#212 local variable: java.lang.ref.ReferenceQueue$Lock#214 at com.mysql.cj.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:85) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#7 local variable: com.mysql.cj.jdbc.AbandonedConnectionCleanupThread#1 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#3 at java.lang.Thread.run(Thread.java:834) "Connector-Scheduler-41da3aee" prio=5 tid=71 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#27 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#63 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1182) local variable: java.util.concurrent.locks.ReentrantLock#139 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:899) local variable: java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue#6 at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) local variable: java.util.concurrent.ScheduledThreadPoolExecutor#6 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#4 at java.lang.Thread.run(Thread.java:834) "DistributedHerder-connect-1" prio=5 tid=59 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.Util$2#5 local variable: sun.nio.ch.EPollSelectorImpl#5 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#4 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#4 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) local variable: org.apache.kafka.common.utils.Timer#20 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:224) at org.apache.kafka.connect.runtime.distributed.WorkerCoordinator.poll(WorkerCoordinator.java:161) at org.apache.kafka.connect.runtime.distributed.WorkerGroupMember.poll(WorkerGroupMember.java:165) local variable: org.apache.kafka.connect.runtime.distributed.WorkerGroupMember#1 at org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:410) local variable: java.util.concurrent.atomic.AtomicReference#66 local variable: java.util.concurrent.atomic.AtomicReference#67 local variable: java.util.concurrent.atomic.AtomicReference#68 at org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:286) local variable: org.apache.kafka.connect.runtime.distributed.DistributedHerder#1 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#1 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#4 local variable: java.util.concurrent.FutureTask#1 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#1 at java.lang.Thread.run(Thread.java:834) "KafkaBasedLog Work Thread - __connect_status" prio=5 tid=66 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#6 local variable: sun.nio.ch.Util$2#6 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#5 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#5 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) local variable: org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient#3 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233) at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1300) local variable: org.apache.kafka.common.utils.Timer#16 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1240) local variable: org.apache.kafka.common.utils.Timer#15 at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211) local variable: org.apache.kafka.clients.consumer.KafkaConsumer#2 local variable: java.time.Duration#26 at org.apache.kafka.connect.util.KafkaBasedLog.poll(KafkaBasedLog.java:267) at org.apache.kafka.connect.util.KafkaBasedLog.access$500(KafkaBasedLog.java:71) at org.apache.kafka.connect.util.KafkaBasedLog$WorkThread.run(KafkaBasedLog.java:348) local variable: org.apache.kafka.connect.util.KafkaBasedLog#2 "kafka-producer-network-thread | producer-2" daemon prio=5 tid=65 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#7 local variable: sun.nio.ch.Util$2#7 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#6 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#6 at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) local variable: org.apache.kafka.clients.producer.internals.Sender#3 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-1" prio=5 tid=72 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#8 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#6 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-2" prio=5 tid=73 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#9 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#7 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-3" prio=5 tid=74 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#10 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#8 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-4" prio=5 tid=75 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#4 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#9 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-6" prio=5 tid=77 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#5 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#10 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-5" prio=5 tid=76 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#11 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#11 at java.lang.Thread.run(Thread.java:834) "kafka-producer-network-thread | connector-producer-[CONNECTOR 4]-0" daemon prio=5 tid=78 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#9 local variable: sun.nio.ch.Util$2#9 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#8 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#8 at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) local variable: org.apache.kafka.clients.producer.internals.Sender#4 at java.lang.Thread.run(Thread.java:834) "task-thread-[CONNECTOR 3]-0" prio=5 tid=81 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.Metronome$1.pause(Metronome.java:57) local variable: io.debezium.util.Metronome$1#3 at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:154) local variable: io.debezium.connector.base.ChangeEventQueue#1 local variable: io.debezium.util.LoggingContext$PreviousContext#1 local variable: java.util.ArrayList#3433 local variable: io.debezium.util.Threads$2#3 at io.debezium.connector.postgresql.PostgresConnectorTask.doPoll(PostgresConnectorTask.java:235) at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:131) local variable: io.debezium.connector.postgresql.PostgresConnectorTask#1 at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:271) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:238) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:178) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:228) local variable: java.lang.String#44724 local variable: org.apache.kafka.connect.runtime.WorkerSourceTask#1 local variable: org.apache.kafka.connect.util.LoggingContext#1 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#3 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.FutureTask#389 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#12 at java.lang.Thread.run(Thread.java:834) "pool-21-thread-1" prio=5 tid=83 TIMED_WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2123) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#36 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#20 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1182) local variable: java.util.concurrent.locks.ReentrantLock#64 at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:899) local variable: java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue#5 at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) local variable: java.util.concurrent.ScheduledThreadPoolExecutor#5 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#13 at java.lang.Thread.run(Thread.java:834) "task-thread-[CONNECTOR 4]-0" prio=5 tid=84 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.Metronome$1.pause(Metronome.java:57) local variable: io.debezium.util.Metronome$1#4 at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:154) local variable: io.debezium.connector.base.ChangeEventQueue#2 local variable: java.util.ArrayList#3437 local variable: io.debezium.util.Threads$2#4 local variable: io.debezium.util.LoggingContext$PreviousContext#2 at io.debezium.connector.postgresql.PostgresConnectorTask.doPoll(PostgresConnectorTask.java:235) at io.debezium.connector.common.BaseSourceTask.poll(BaseSourceTask.java:131) local variable: io.debezium.connector.postgresql.PostgresConnectorTask#2 at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:271) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:238) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:178) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:228) local variable: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader#1 local variable: org.apache.kafka.connect.runtime.WorkerSourceTask#2 local variable: org.apache.kafka.connect.util.LoggingContext#2 local variable: java.lang.String#52025 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#5 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#3 local variable: java.util.concurrent.FutureTask#391 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#14 at java.lang.Thread.run(Thread.java:834) "pool-22-thread-1" prio=5 tid=88 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.Metronome$1.pause(Metronome.java:57) local variable: io.debezium.util.Metronome$1#1 at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:517) local variable: io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1#1 local variable: org.postgresql.core.v3.replication.V3PGReplicationStream#1 at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1$$Lambda$760.run() local variable: io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1$$Lambda$760#2 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#6 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#10 local variable: java.util.concurrent.FutureTask#392 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#15 at java.lang.Thread.run(Thread.java:834) "pool-25-thread-1" prio=5 tid=95 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.Metronome$1.pause(Metronome.java:57) local variable: io.debezium.util.Metronome$1#2 at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.lambda$startKeepAlive$0(PostgresReplicationConnection.java:517) local variable: io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1#2 local variable: org.postgresql.core.v3.replication.V3PGReplicationStream#2 at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1$$Lambda$760.run() local variable: io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1$$Lambda$760#1 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#2 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.FutureTask#388 local variable: java.util.concurrent.ThreadPoolExecutor#12 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#16 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-7" prio=5 tid=90 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#12 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#17 at java.lang.Thread.run(Thread.java:834) "pool-19-thread-8" prio=5 tid=91 WAITING at jdk.internal.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2081) local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#18 local variable: java.util.concurrent.locks.AbstractQueuedSynchronizer$Node#13 at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:433) local variable: java.util.concurrent.LinkedBlockingQueue#4 local variable: java.util.concurrent.atomic.AtomicInteger#34 local variable: java.util.concurrent.locks.ReentrantLock#22 at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1114) local variable: java.util.concurrent.ThreadPoolExecutor#6 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#18 at java.lang.Thread.run(Thread.java:834) "kafka-producer-network-thread | connector-producer-[CONNECTOR 3]-0" daemon prio=5 tid=93 RUNNABLE at sun.nio.ch.EPoll.wait(Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:124) local variable: sun.nio.ch.EPollSelectorImpl#10 local variable: sun.nio.ch.Util$2#10 at sun.nio.ch.SelectorImpl.select(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) local variable: org.apache.kafka.common.network.Selector#9 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:549) local variable: org.apache.kafka.clients.NetworkClient#9 at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:335) at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:244) local variable: org.apache.kafka.clients.producer.internals.Sender#5 at java.lang.Thread.run(Thread.java:834) "debezium-postgresconnector-[CONNECTOR 2]" prio=5 tid=94 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.DelayStrategy.lambda$constant$1(DelayStrategy.java:58) at io.debezium.util.DelayStrategy$$Lambda$753.sleepWhen() at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.searchWalPosition(PostgresStreamingChangeEventSource.java:265) local variable: java.util.concurrent.atomic.AtomicReference#42 at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:125) local variable: io.debezium.connector.postgresql.PostgresStreamingChangeEventSource#2 local variable: io.debezium.connector.postgresql.connection.WalPositionLocator#2 at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) local variable: io.debezium.pipeline.ChangeEventSourceCoordinator$ChangeEventSourceContextImpl#2 local variable: io.debezium.pipeline.ChangeEventSourceCoordinator#1 local variable: io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource#1 local variable: io.debezium.pipeline.spi.SnapshotResult#1 at io.debezium.pipeline.ChangeEventSourceCoordinator$$Lambda$751.run() local variable: io.debezium.pipeline.ChangeEventSourceCoordinator$$Lambda$751#1 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#4 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#13 local variable: java.util.concurrent.FutureTask#390 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#19 at java.lang.Thread.run(Thread.java:834) "debezium-postgresconnector-[CONNECTOR 1]" prio=5 tid=87 TIMED_WAITING at java.lang.Thread.sleep(Native Method) at io.debezium.util.DelayStrategy.lambda$constant$1(DelayStrategy.java:58) at io.debezium.util.DelayStrategy$$Lambda$753.sleepWhen() at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.searchWalPosition(PostgresStreamingChangeEventSource.java:265) local variable: java.util.concurrent.atomic.AtomicReference#40 at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:125) local variable: io.debezium.connector.postgresql.PostgresStreamingChangeEventSource#1 local variable: io.debezium.connector.postgresql.connection.WalPositionLocator#1 at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108) local variable: io.debezium.pipeline.ChangeEventSourceCoordinator$ChangeEventSourceContextImpl#1 local variable: io.debezium.pipeline.ChangeEventSourceCoordinator#2 local variable: io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource#2 local variable: io.debezium.pipeline.spi.SnapshotResult#2 at io.debezium.pipeline.ChangeEventSourceCoordinator$$Lambda$751.run() local variable: io.debezium.pipeline.ChangeEventSourceCoordinator$$Lambda$751#2 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) local variable: java.util.concurrent.Executors$RunnableAdapter#7 at java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: java.util.concurrent.ThreadPoolExecutor#8 local variable: java.util.concurrent.FutureTask#393 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#5 at java.lang.Thread.run(Thread.java:834) "mysql-cj-abandoned-connection-cleanup" daemon prio=5 tid=27 TIMED_WAITING at java.lang.Object.wait(Native Method) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155) local variable: java.lang.ref.ReferenceQueue$Lock#430 local variable: java.lang.ref.ReferenceQueue#428 at com.mysql.cj.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:85) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) local variable: com.mysql.cj.jdbc.AbandonedConnectionCleanupThread#1 local variable: java.util.concurrent.ThreadPoolExecutor#15 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) local variable: java.util.concurrent.ThreadPoolExecutor$Worker#20 at java.lang.Thread.run(Thread.java:834) "qtp640275932-52-acceptor-0@[REDACTED]" prio=3 tid=52 RUNNABLE at sun.nio.ch.ServerSocketChannelImpl.accept0(Native Method) at sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:533) local variable: java.io.FileDescriptor#381 at sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:285) local variable: java.io.FileDescriptor#311 local variable: java.net.InetSocketAddress[]#1 at org.eclipse.jetty.server.ServerConnector.accept(ServerConnector.java:385) local variable: org.eclipse.jetty.server.ServerConnector#1 local variable: sun.nio.ch.ServerSocketChannelImpl#2 at org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:664) local variable: org.eclipse.jetty.util.thread.Locker$Lock#1 local variable: java.lang.String#29503 at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918) local variable: org.eclipse.jetty.server.AbstractConnector$Acceptor#1 at java.lang.Thread.run(Thread.java:834) "Attach Listener" daemon prio=9 tid=96 RUNNABLE