2021-08-27 11:24:58 Full thread dump OpenJDK 64-Bit Server VM (11.0.4+11 mixed mode): Threads class SMR info: _java_thread_list=0x00007f8af00029d0, length=121, elements={ 0x00007f8b1c0e5000, 0x00007f8b1c0e7000, 0x00007f8b1c0fd000, 0x00007f8b1c0ff000, 0x00007f8b1c101000, 0x00007f8b1c104000, 0x00007f8b1c182800, 0x00007f8b1c18b800, 0x00007f8b1c997800, 0x00007f8b1d035800, 0x00007f8b1d03c000, 0x00007f8b1d044000, 0x00007f8b1d14e000, 0x00007f8b1cd3b000, 0x00007f8b1d584800, 0x00007f8b1d5a7800, 0x00007f8b1d51e800, 0x00007f8b1d551800, 0x00007f8b1d543000, 0x00007f8b1d4c9800, 0x00007f8b1d544800, 0x00007f8b1d545800, 0x00007f8b1d55e800, 0x00007f8b1d43e000, 0x00007f8b1d3d2800, 0x00007f8b1d4f1000, 0x00007f8b1d51f800, 0x00007f8b1d51c000, 0x00007f8b1d529800, 0x00007f8b1d518800, 0x00007f8b1d4d9000, 0x00007f8b1d4c1800, 0x00007f8b1d577800, 0x00007f8b1d52c000, 0x00007f8b1d4d6000, 0x00007f8b1d4f7000, 0x00007f8b1d5a6000, 0x00007f8b1d464800, 0x00007f8b1d581800, 0x00007f8b1d45f000, 0x00007f8b1d469800, 0x00007f8b1d4d4000, 0x00007f8b1d5e3800, 0x00007f8b1d4f5000, 0x00007f8b1d4de000, 0x00007f8b1d5c4000, 0x00007f8b1d4e1000, 0x00007f8b1d5c6800, 0x00007f8b1d5d3000, 0x00007f8b1d36d800, 0x00007f8b1d453000, 0x00007f8b1d370800, 0x00007f8b1d4ad800, 0x00007f8b1d5d4800, 0x00007f8b1d58d800, 0x00007f8b1d54b800, 0x00007f8b1d5e8800, 0x00007f8b1d5cc000, 0x00007f8b1d5bf000, 0x00007f8b1d5c0000, 0x00007f8b1d571000, 0x00007f8b1d609800, 0x00007f8b1d60e000, 0x00007f8b1d610000, 0x00007f8b1d614800, 0x00007f8b1d616800, 0x00007f8b1d61b800, 0x00007f8b1d61d800, 0x00007f8b1d622800, 0x00007f8b1d624000, 0x00007f8b1d629800, 0x00007f8b1d62b000, 0x00007f8b1d630000, 0x00007f8b1d632000, 0x00007f8b1d63e000, 0x00007f8b1d63f000, 0x00007f8b1d63a800, 0x00007f8b1d63c800, 0x00007f8b1d644000, 0x00007f8b1d646000, 0x00007f8b1d648000, 0x00007f8b1d649800, 0x00007f8b1d64b800, 0x00007f8b1d64d800, 0x00007f8b1d64f800, 0x00007f8b1d655800, 0x00007f8b1d660000, 0x00007f8b1c010800, 0x00007f89fc011800, 0x00007f89f4007800, 0x00007f8aa8080800, 0x00007f8a70004800, 0x00007f8a48006000, 0x00007f8a50005800, 0x00007f89ec007800, 0x00007f89d4004800, 0x00007f89e4005800, 0x00007f8a24002800, 0x00007f8a98005000, 0x00007f8a58010800, 0x00007f89dc006800, 0x00007f8a80005000, 0x00007f8a0c005800, 0x00007f8a60005000, 0x00007f8aa0004000, 0x00007f8a3c005000, 0x00007f8a1c002800, 0x00007f89cc00d000, 0x00007f8a04013000, 0x00007f8a14040000, 0x00007f8a3400b800, 0x00007f8a2c006000, 0x00007f8a78005800, 0x00007f8ab8137000, 0x00007f8a8800b800, 0x00007f8ab0002800, 0x00007f8a68006000, 0x00007f8a90009000, 0x00007f8ad019e800, 0x00007f8920003800, 0x00007f8af0001000 } "Reference Handler" #2 daemon prio=10 os_prio=0 cpu=145.28ms elapsed=235637.23s tid=0x00007f8b1c0e5000 nid=0x8 waiting on condition [0x00007f8b22910000] java.lang.Thread.State: RUNNABLE at java.lang.ref.Reference.waitForReferencePendingList(java.base@11.0.4/Native Method) at java.lang.ref.Reference.processPendingReferences(java.base@11.0.4/Unknown Source) at java.lang.ref.Reference$ReferenceHandler.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "Finalizer" #3 daemon prio=8 os_prio=0 cpu=0.29ms elapsed=235637.23s tid=0x00007f8b1c0e7000 nid=0x9 in Object.wait() [0x00007f8b2280f000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on <0x00000000f8b81cc8> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.4/Unknown Source) - waiting to re-lock in wait() <0x00000000f8b81cc8> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.4/Unknown Source) at java.lang.ref.Finalizer$FinalizerThread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "Signal Dispatcher" #4 daemon prio=9 os_prio=0 cpu=0.51ms elapsed=235637.18s tid=0x00007f8b1c0fd000 nid=0xa runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 cpu=31217.92ms elapsed=235637.18s tid=0x00007f8b1c0ff000 nid=0xb waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task Locked ownable synchronizers: - None "C1 CompilerThread0" #6 daemon prio=9 os_prio=0 cpu=4376.41ms elapsed=235637.18s tid=0x00007f8b1c101000 nid=0xc waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task Locked ownable synchronizers: - None "Sweeper thread" #7 daemon prio=9 os_prio=0 cpu=3496.52ms elapsed=235637.18s tid=0x00007f8b1c104000 nid=0xd runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Service Thread" #8 daemon prio=9 os_prio=0 cpu=0.10ms elapsed=235637.16s tid=0x00007f8b1c182800 nid=0xe runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "Common-Cleaner" #9 daemon prio=8 os_prio=0 cpu=123.23ms elapsed=235637.16s tid=0x00007f8b1c18b800 nid=0x10 in Object.wait() [0x00007f8b21f55000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.ref.ReferenceQueue.remove(java.base@11.0.4/Unknown Source) - waiting to re-lock in wait() <0x00000000f8b824e0> (a java.lang.ref.ReferenceQueue$Lock) at jdk.internal.ref.CleanerImpl.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) at jdk.internal.misc.InnocuousThread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "BatchNotifier" #14 prio=5 os_prio=0 cpu=8169.47ms elapsed=235635.95s tid=0x00007f8b1c997800 nid=0x12 in Object.wait() [0x00007f8b206f5000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.util.TimerThread.mainLoop(java.base@11.0.4/Unknown Source) - waiting to re-lock in wait() <0x00000000f8f39608> (a java.util.TaskQueue) at java.util.TimerThread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "Catalina-utility-1" #16 prio=1 os_prio=0 cpu=7064.16ms elapsed=235629.76s tid=0x00007f8b1d035800 nid=0x13 waiting on condition [0x00007f8b21a2b000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9269cc0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "Catalina-utility-2" #17 prio=1 os_prio=0 cpu=6616.03ms elapsed=235629.75s tid=0x00007f8b1d03c000 nid=0x14 waiting on condition [0x00007f8b201f4000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9269cc0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "container-0" #18 prio=5 os_prio=0 cpu=490.04ms elapsed=235629.75s tid=0x00007f8b1d044000 nid=0x15 waiting on condition [0x00007f8b06db9000] java.lang.Thread.State: TIMED_WAITING (sleeping) at java.lang.Thread.sleep(java.base@11.0.4/Native Method) at org.apache.catalina.core.StandardServer.await(StandardServer.java:570) at org.springframework.boot.web.embedded.tomcat.TomcatWebServer$1.run(TomcatWebServer.java:197) Locked ownable synchronizers: - None "cluster-ClusterId{value='6125331c18254e52a31b5d17', description='null'}-172.21.110.27:27017" #19 daemon prio=5 os_prio=0 cpu=4368.39ms elapsed=235629.61s tid=0x00007f8b1d14e000 nid=0x16 waiting on condition [0x00007f8b06ab8000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9349778> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.waitForSignalOrTimeout(DefaultServerMonitor.java:228) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.waitForNext(DefaultServerMonitor.java:209) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:157) - locked <0x00000000f9349790> (a com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "cluster-ClusterId{value='6125331c18254e52a31b5d17', description='null'}-172.21.110.40:27017" #20 daemon prio=5 os_prio=0 cpu=4388.06ms elapsed=235629.61s tid=0x00007f8b1cd3b000 nid=0x17 waiting on condition [0x00007f8b069b7000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9349958> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.waitForSignalOrTimeout(DefaultServerMonitor.java:228) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.waitForNext(DefaultServerMonitor.java:209) at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:157) - locked <0x00000000f9349970> (a com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #21 prio=5 os_prio=0 cpu=273.23ms elapsed=235628.92s tid=0x00007f8b1d584800 nid=0x18 waiting on condition [0x00007f8b060b4000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f95812b8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-0-C-1" #22 prio=5 os_prio=0 cpu=71930.06ms elapsed=235628.92s tid=0x00007f8b1d5a7800 nid=0x19 runnable [0x00007f8b05fb2000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #23 prio=5 os_prio=0 cpu=211.01ms elapsed=235628.91s tid=0x00007f8b1d51e800 nid=0x1a waiting on condition [0x00007f8b05eb2000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9581758> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-1-C-1" #24 prio=5 os_prio=0 cpu=61332.11ms elapsed=235628.91s tid=0x00007f8b1d551800 nid=0x1b runnable [0x00007f8b05db0000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #25 prio=5 os_prio=0 cpu=202.36ms elapsed=235628.90s tid=0x00007f8b1d543000 nid=0x1c waiting on condition [0x00007f8b05cb0000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9602830> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-2-C-1" #26 prio=5 os_prio=0 cpu=68810.59ms elapsed=235628.90s tid=0x00007f8b1d4c9800 nid=0x1d runnable [0x00007f8b05bae000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:76) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #27 prio=5 os_prio=0 cpu=231.31ms elapsed=235628.89s tid=0x00007f8b1d544800 nid=0x1e waiting on condition [0x00007f8b05aae000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9602c28> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-3-C-1" #28 prio=5 os_prio=0 cpu=62839.30ms elapsed=235628.89s tid=0x00007f8b1d545800 nid=0x1f runnable [0x00007f8b059ac000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #29 prio=5 os_prio=0 cpu=199.64ms elapsed=235628.88s tid=0x00007f8b1d55e800 nid=0x20 waiting on condition [0x00007f8b056ac000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9603250> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-4-C-1" #30 prio=5 os_prio=0 cpu=62400.77ms elapsed=235628.88s tid=0x00007f8b1d43e000 nid=0x21 runnable [0x00007f8b055aa000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #31 prio=5 os_prio=0 cpu=206.96ms elapsed=235628.88s tid=0x00007f8b1d3d2800 nid=0x22 waiting on condition [0x00007f8b054aa000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9603878> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-5-C-1" #32 prio=5 os_prio=0 cpu=72024.61ms elapsed=235628.88s tid=0x00007f8b1d4f1000 nid=0x23 runnable [0x00007f8b053a8000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #33 prio=5 os_prio=0 cpu=204.71ms elapsed=235628.87s tid=0x00007f8b1d51f800 nid=0x24 waiting on condition [0x00007f8b052a8000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9603ea0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-6-C-1" #34 prio=5 os_prio=0 cpu=65676.16ms elapsed=235628.87s tid=0x00007f8b1d51c000 nid=0x25 runnable [0x00007f8b051a6000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #35 prio=5 os_prio=0 cpu=183.47ms elapsed=235628.87s tid=0x00007f8b1d529800 nid=0x26 waiting on condition [0x00007f8b050a6000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f96044c8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-7-C-1" #36 prio=5 os_prio=0 cpu=60723.65ms elapsed=235628.87s tid=0x00007f8b1d518800 nid=0x27 runnable [0x00007f8b04fa4000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #37 prio=5 os_prio=0 cpu=205.05ms elapsed=235628.86s tid=0x00007f8b1d4d9000 nid=0x28 waiting on condition [0x00007f8b04ea4000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9604af0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-8-C-1" #38 prio=5 os_prio=0 cpu=73617.04ms elapsed=235628.86s tid=0x00007f8b1d4c1800 nid=0x29 runnable [0x00007f8b04da2000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #39 prio=5 os_prio=0 cpu=202.62ms elapsed=235628.86s tid=0x00007f8b1d577800 nid=0x2a waiting on condition [0x00007f8b04ca2000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9605118> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-9-C-1" #40 prio=5 os_prio=0 cpu=68131.45ms elapsed=235628.86s tid=0x00007f8b1d52c000 nid=0x2b runnable [0x00007f8b04ba0000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:76) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #41 prio=5 os_prio=0 cpu=176.65ms elapsed=235628.85s tid=0x00007f8b1d4d6000 nid=0x2c waiting on condition [0x00007f8b04aa0000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9605740> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-10-C-1" #42 prio=5 os_prio=0 cpu=68799.14ms elapsed=235628.85s tid=0x00007f8b1d4f7000 nid=0x2d runnable [0x00007f8b0499e000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #43 prio=5 os_prio=0 cpu=203.73ms elapsed=235628.85s tid=0x00007f8b1d5a6000 nid=0x2e waiting on condition [0x00007f8b0489e000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9605d68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-11-C-1" #44 prio=5 os_prio=0 cpu=65718.31ms elapsed=235628.85s tid=0x00007f8b1d464800 nid=0x2f runnable [0x00007f8b0479c000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #45 prio=5 os_prio=0 cpu=185.59ms elapsed=235628.85s tid=0x00007f8b1d581800 nid=0x30 waiting on condition [0x00007f8b0469c000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9606390> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-12-C-1" #46 prio=5 os_prio=0 cpu=60380.64ms elapsed=235628.85s tid=0x00007f8b1d45f000 nid=0x31 runnable [0x00007f8b0459a000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #47 prio=5 os_prio=0 cpu=221.90ms elapsed=235628.83s tid=0x00007f8b1d469800 nid=0x32 waiting on condition [0x00007f8b0449a000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f96e6860> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-13-C-1" #48 prio=5 os_prio=0 cpu=66063.03ms elapsed=235628.83s tid=0x00007f8b1d4d4000 nid=0x33 runnable [0x00007f8b04398000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #49 prio=5 os_prio=0 cpu=200.46ms elapsed=235628.82s tid=0x00007f8b1d5e3800 nid=0x34 waiting on condition [0x00007f8b04298000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f96e6f48> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-14-C-1" #50 prio=5 os_prio=0 cpu=64891.19ms elapsed=235628.82s tid=0x00007f8b1d4f5000 nid=0x35 runnable [0x00007f8b04196000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #51 prio=5 os_prio=0 cpu=191.42ms elapsed=235628.82s tid=0x00007f8b1d4de000 nid=0x36 waiting on condition [0x00007f8a4fffe000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f96e7630> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-15-C-1" #52 prio=5 os_prio=0 cpu=64984.87ms elapsed=235628.82s tid=0x00007f8b1d5c4000 nid=0x37 runnable [0x00007f8a4fefc000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:76) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #53 prio=5 os_prio=0 cpu=227.14ms elapsed=235628.82s tid=0x00007f8b1d4e1000 nid=0x38 waiting on condition [0x00007f8a4fdfc000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f96e7d18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-16-C-1" #54 prio=5 os_prio=0 cpu=63952.41ms elapsed=235628.82s tid=0x00007f8b1d5c6800 nid=0x39 runnable [0x00007f8a4fcfa000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:76) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #55 prio=5 os_prio=0 cpu=229.30ms elapsed=235628.78s tid=0x00007f8b1d5d3000 nid=0x3a waiting on condition [0x00007f8a4f9fa000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977d740> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-17-C-1" #56 prio=5 os_prio=0 cpu=66972.90ms elapsed=235628.78s tid=0x00007f8b1d36d800 nid=0x3b runnable [0x00007f8a4f8f8000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #57 prio=5 os_prio=0 cpu=231.73ms elapsed=235628.78s tid=0x00007f8b1d453000 nid=0x3c waiting on condition [0x00007f8a4f7f8000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977dc28> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-18-C-1" #58 prio=5 os_prio=0 cpu=68762.32ms elapsed=235628.78s tid=0x00007f8b1d370800 nid=0x3d runnable [0x00007f8a4f6f6000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #59 prio=5 os_prio=0 cpu=201.31ms elapsed=235628.77s tid=0x00007f8b1d4ad800 nid=0x3e waiting on condition [0x00007f8a4f5f6000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977e310> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-19-C-1" #60 prio=5 os_prio=0 cpu=60953.75ms elapsed=235628.77s tid=0x00007f8b1d5d4800 nid=0x3f runnable [0x00007f8a4f4f4000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #61 prio=5 os_prio=0 cpu=177.49ms elapsed=235628.77s tid=0x00007f8b1d58d800 nid=0x40 waiting on condition [0x00007f8a4f3f4000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977e9f8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-20-C-1" #62 prio=5 os_prio=0 cpu=67691.13ms elapsed=235628.77s tid=0x00007f8b1d54b800 nid=0x41 runnable [0x00007f8a4f2f2000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #63 prio=5 os_prio=0 cpu=188.90ms elapsed=235628.77s tid=0x00007f8b1d5e8800 nid=0x42 waiting on condition [0x00007f8a4f1f2000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977f0e0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-21-C-1" #64 prio=5 os_prio=0 cpu=63740.61ms elapsed=235628.77s tid=0x00007f8b1d5cc000 nid=0x43 runnable [0x00007f8a4f0f0000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #65 prio=5 os_prio=0 cpu=192.16ms elapsed=235628.77s tid=0x00007f8b1d5bf000 nid=0x44 waiting on condition [0x00007f8a4eff0000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977f7c8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-22-C-1" #66 prio=5 os_prio=0 cpu=64875.19ms elapsed=235628.77s tid=0x00007f8b1d5c0000 nid=0x45 runnable [0x00007f8a4eeee000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #67 prio=5 os_prio=0 cpu=165.64ms elapsed=235628.76s tid=0x00007f8b1d571000 nid=0x46 waiting on condition [0x00007f8a4edee000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f977feb0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-23-C-1" #68 prio=5 os_prio=0 cpu=64925.33ms elapsed=235628.76s tid=0x00007f8b1d609800 nid=0x47 runnable [0x00007f8a4ecec000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #69 prio=5 os_prio=0 cpu=156.13ms elapsed=235628.76s tid=0x00007f8b1d60e000 nid=0x48 waiting on condition [0x00007f8a4ebec000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f9780598> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-24-C-1" #70 prio=5 os_prio=0 cpu=61360.54ms elapsed=235628.76s tid=0x00007f8b1d610000 nid=0x49 runnable [0x00007f8a4eaea000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #71 prio=5 os_prio=0 cpu=180.03ms elapsed=235628.75s tid=0x00007f8b1d614800 nid=0x4a waiting on condition [0x00007f8a4e9ea000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982db88> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-25-C-1" #72 prio=5 os_prio=0 cpu=64728.01ms elapsed=235628.75s tid=0x00007f8b1d616800 nid=0x4b runnable [0x00007f8a4e8e8000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #73 prio=5 os_prio=0 cpu=184.61ms elapsed=235628.75s tid=0x00007f8b1d61b800 nid=0x4c waiting on condition [0x00007f8a4e7e8000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982e1b8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-26-C-1" #74 prio=5 os_prio=0 cpu=69591.23ms elapsed=235628.75s tid=0x00007f8b1d61d800 nid=0x4d runnable [0x00007f8a4e6e6000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #75 prio=5 os_prio=0 cpu=163.10ms elapsed=235628.75s tid=0x00007f8b1d622800 nid=0x4e waiting on condition [0x00007f8a4e5e6000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982e918> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-27-C-1" #76 prio=5 os_prio=0 cpu=67764.06ms elapsed=235628.75s tid=0x00007f8b1d624000 nid=0x4f runnable [0x00007f8a4e4e4000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #77 prio=5 os_prio=0 cpu=167.18ms elapsed=235628.74s tid=0x00007f8b1d629800 nid=0x50 waiting on condition [0x00007f8a4e3e4000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982f078> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-28-C-1" #78 prio=5 os_prio=0 cpu=60455.33ms elapsed=235628.74s tid=0x00007f8b1d62b000 nid=0x51 runnable [0x00007f8a4e2e2000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "ThreadPoolTaskScheduler-1" #79 prio=5 os_prio=0 cpu=233.36ms elapsed=235628.71s tid=0x00007f8b1d630000 nid=0x52 waiting on condition [0x00007f8a4e1e2000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982f7c8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "product_spring_aggregator_tunnelstats_groupid_prod-29-C-1" #80 prio=5 os_prio=0 cpu=60699.88ms elapsed=235628.71s tid=0x00007f8b1d632000 nid=0x53 runnable [0x00007f8a4e0e0000] java.lang.Thread.State: RUNNABLE at java.net.SocketInputStream.socketRead0(java.base@11.0.4/Native Method) at java.net.SocketInputStream.socketRead(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at java.net.SocketInputStream.read(java.base@11.0.4/Unknown Source) at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:109) at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:579) at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:444) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:298) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:258) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:99) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:500) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:224) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:202) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:118) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeCommand(MixedBulkWriteOperation.java:419) at com.mongodb.internal.operation.MixedBulkWriteOperation.executeBulkWriteBatch(MixedBulkWriteOperation.java:245) at com.mongodb.internal.operation.MixedBulkWriteOperation.access$700(MixedBulkWriteOperation.java:71) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:189) at com.mongodb.internal.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.OperationHelper.withReleasableConnection(OperationHelper.java:500) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:180) at com.mongodb.internal.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:71) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:207) at com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1008) at com.mongodb.client.internal.MongoCollectionImpl.executeInsertOne(MongoCollectionImpl.java:469) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:452) at com.mongodb.client.internal.MongoCollectionImpl.insertOne(MongoCollectionImpl.java:446) at org.springframework.data.mongodb.core.MongoTemplate.lambda$insertDocument$15(MongoTemplate.java:1442) at org.springframework.data.mongodb.core.MongoTemplate$$Lambda$1411/0x00000001006a9840.doInCollection(Unknown Source) at org.springframework.data.mongodb.core.MongoTemplate.execute(MongoTemplate.java:566) at org.springframework.data.mongodb.core.MongoTemplate.insertDocument(MongoTemplate.java:1436) at org.springframework.data.mongodb.core.MongoTemplate.doInsert(MongoTemplate.java:1236) at org.springframework.data.mongodb.core.MongoTemplate.insert(MongoTemplate.java:1168) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.lambda$saveTunnelStats$0(TunnelStatsServiceImpl.java:74) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl$$Lambda$1298/0x00000001007e5440.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.4/Unknown Source) at com.test.product.aggregator.service.impl.TunnelStatsServiceImpl.saveTunnelStats(TunnelStatsServiceImpl.java:71) at com.test.product.aggregator.listener.TunnelStatsListener.consumeTunnelStatsData(TunnelStatsListener.java:31) at jdk.internal.reflect.GeneratedMethodAccessor119.invoke(Unknown Source) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.4/Unknown Source) at java.lang.reflect.Method.invoke(java.base@11.0.4/Unknown Source) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:329) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2004) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1986) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1923) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1863) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1757) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1478) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1141) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1044) at java.util.concurrent.Executors$RunnableAdapter.call(java.base@11.0.4/Unknown Source) at java.util.concurrent.FutureTask.run(java.base@11.0.4/Unknown Source) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-BlockPoller" #81 daemon prio=5 os_prio=0 cpu=3905.60ms elapsed=235628.70s tid=0x00007f8b1d63e000 nid=0x54 runnable [0x00007f8a4dfe0000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.4/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.4/Unknown Source) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.4/Unknown Source) - locked <0x00000000f982ff90> (a sun.nio.ch.Util$2) - locked <0x00000000f982ff38> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.net.NioBlockingSelector$BlockPoller.run(NioBlockingSelector.java:313) Locked ownable synchronizers: - None "http-nio-5070-exec-1" #82 daemon prio=5 os_prio=0 cpu=0.18ms elapsed=235628.70s tid=0x00007f8b1d63f000 nid=0x55 waiting on condition [0x00007f8a4dedf000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-2" #83 daemon prio=5 os_prio=0 cpu=0.20ms elapsed=235628.70s tid=0x00007f8b1d63a800 nid=0x56 waiting on condition [0x00007f8a4ddde000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-3" #84 daemon prio=5 os_prio=0 cpu=0.13ms elapsed=235628.70s tid=0x00007f8b1d63c800 nid=0x57 waiting on condition [0x00007f8a4dcdd000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-4" #85 daemon prio=5 os_prio=0 cpu=0.14ms elapsed=235628.70s tid=0x00007f8b1d644000 nid=0x58 waiting on condition [0x00007f8a4dbdc000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-5" #86 daemon prio=5 os_prio=0 cpu=0.16ms elapsed=235628.70s tid=0x00007f8b1d646000 nid=0x59 waiting on condition [0x00007f8a4dadb000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-6" #87 daemon prio=5 os_prio=0 cpu=0.14ms elapsed=235628.70s tid=0x00007f8b1d648000 nid=0x5a waiting on condition [0x00007f8a4d9da000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-7" #88 daemon prio=5 os_prio=0 cpu=0.14ms elapsed=235628.70s tid=0x00007f8b1d649800 nid=0x5b waiting on condition [0x00007f8a4d8d9000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-8" #89 daemon prio=5 os_prio=0 cpu=0.16ms elapsed=235628.70s tid=0x00007f8b1d64b800 nid=0x5c waiting on condition [0x00007f8a4d7d8000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-9" #90 daemon prio=5 os_prio=0 cpu=0.14ms elapsed=235628.70s tid=0x00007f8b1d64d800 nid=0x5d waiting on condition [0x00007f8a4d6d7000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-exec-10" #91 daemon prio=5 os_prio=0 cpu=0.14ms elapsed=235628.70s tid=0x00007f8b1d64f800 nid=0x5e waiting on condition [0x00007f8a4d5d6000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.4/Native Method) - parking to wait for <0x00000000f982ffa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.4/Unknown Source) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.4/Unknown Source) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:108) at org.apache.tomcat.util.threads.TaskQueue.take(TaskQueue.java:33) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.4/Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-ClientPoller" #92 daemon prio=5 os_prio=0 cpu=4383.48ms elapsed=235628.69s tid=0x00007f8b1d655800 nid=0x5f runnable [0x00007f8a4d4d5000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.4/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.4/Unknown Source) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.4/Unknown Source) - locked <0x00000000f9909a68> (a sun.nio.ch.Util$2) - locked <0x00000000f9909a10> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.net.NioEndpoint$Poller.run(NioEndpoint.java:709) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "http-nio-5070-Acceptor" #93 daemon prio=5 os_prio=0 cpu=0.33ms elapsed=235628.69s tid=0x00007f8b1d660000 nid=0x60 runnable [0x00007f8a4d3d4000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.ServerSocketChannelImpl.accept0(java.base@11.0.4/Native Method) at sun.nio.ch.ServerSocketChannelImpl.accept(java.base@11.0.4/Unknown Source) at sun.nio.ch.ServerSocketChannelImpl.accept(java.base@11.0.4/Unknown Source) at org.apache.tomcat.util.net.NioEndpoint.serverSocketAccept(NioEndpoint.java:469) at org.apache.tomcat.util.net.NioEndpoint.serverSocketAccept(NioEndpoint.java:71) at org.apache.tomcat.util.net.Acceptor.run(Acceptor.java:106) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - <0x00000000f985fcb0> (a java.util.concurrent.locks.ReentrantLock$NonfairSync) "DestroyJavaVM" #94 prio=5 os_prio=0 cpu=3166.96ms elapsed=235628.60s tid=0x00007f8b1c010800 nid=0x6 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #96 daemon prio=5 os_prio=0 cpu=18556.38ms elapsed=235628.49s tid=0x00007f89fc011800 nid=0x61 in Object.wait() [0x00007f8a4d0d3000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f97801b0> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #98 daemon prio=5 os_prio=0 cpu=18071.53ms elapsed=235628.49s tid=0x00007f89f4007800 nid=0x62 in Object.wait() [0x00007f8a4cfd2000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9780898> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #97 daemon prio=5 os_prio=0 cpu=18243.46ms elapsed=235628.49s tid=0x00007f8aa8080800 nid=0x63 in Object.wait() [0x00007f8a4ced1000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9581c08> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #99 daemon prio=5 os_prio=0 cpu=18275.32ms elapsed=235628.49s tid=0x00007f8a70004800 nid=0x64 in Object.wait() [0x00007f8a4cdd0000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9605358> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #100 daemon prio=5 os_prio=0 cpu=18644.23ms elapsed=235628.49s tid=0x00007f8a48006000 nid=0x65 in Object.wait() [0x00007f8a4cccf000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96e7248> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #102 daemon prio=5 os_prio=0 cpu=17786.67ms elapsed=235628.49s tid=0x00007f8a50005800 nid=0x66 in Object.wait() [0x00007f8a4cbce000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96e6b60> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #103 daemon prio=5 os_prio=0 cpu=18399.71ms elapsed=235628.49s tid=0x00007f89ec007800 nid=0x67 in Object.wait() [0x00007f8a4cacd000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f982df58> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #105 daemon prio=5 os_prio=0 cpu=18495.69ms elapsed=235628.49s tid=0x00007f89d4004800 nid=0x68 in Object.wait() [0x00007f8a4c9cc000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f982f3e0> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #107 daemon prio=5 os_prio=0 cpu=17723.40ms elapsed=235628.49s tid=0x00007f89e4005800 nid=0x69 in Object.wait() [0x00007f8a4c8cb000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f982e530> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #109 daemon prio=5 os_prio=0 cpu=17903.16ms elapsed=235628.49s tid=0x00007f8a24002800 nid=0x6a in Object.wait() [0x00007f8a4c7ca000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977df28> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #111 daemon prio=5 os_prio=0 cpu=18272.39ms elapsed=235628.49s tid=0x00007f8a98005000 nid=0x6b in Object.wait() [0x00007f8a4c6c9000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9603490> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #113 daemon prio=5 os_prio=0 cpu=17991.50ms elapsed=235628.49s tid=0x00007f8a58010800 nid=0x6c in Object.wait() [0x00007f8a4c5c8000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96065d0> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #112 daemon prio=5 os_prio=0 cpu=17723.83ms elapsed=235628.49s tid=0x00007f89dc006800 nid=0x6d in Object.wait() [0x00007f8a4c4c7000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f982ec90> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #110 daemon prio=5 os_prio=0 cpu=18384.00ms elapsed=235628.49s tid=0x00007f8a80005000 nid=0x6e in Object.wait() [0x00007f8a4c3c6000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9604708> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #108 daemon prio=5 os_prio=0 cpu=17914.74ms elapsed=235628.49s tid=0x00007f8a0c005800 nid=0x6f in Object.wait() [0x00007f8a4c2c5000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977f3e0> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #106 daemon prio=5 os_prio=0 cpu=18388.79ms elapsed=235628.48s tid=0x00007f8a60005000 nid=0x70 in Object.wait() [0x00007f8a4c1c4000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9605fa8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #104 daemon prio=5 os_prio=0 cpu=18552.80ms elapsed=235628.48s tid=0x00007f8aa0004000 nid=0x71 in Object.wait() [0x00007f895bffe000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9602e68> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #101 daemon prio=5 os_prio=0 cpu=18009.11ms elapsed=235628.48s tid=0x00007f8a3c005000 nid=0x72 in Object.wait() [0x00007f895befd000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96e7930> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #118 daemon prio=5 os_prio=0 cpu=17811.76ms elapsed=235628.48s tid=0x00007f8a1c002800 nid=0x73 in Object.wait() [0x00007f895bdfc000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977e610> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #117 daemon prio=5 os_prio=0 cpu=18286.84ms elapsed=235628.48s tid=0x00007f89cc00d000 nid=0x74 in Object.wait() [0x00007f895bcfb000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f982fb40> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #116 daemon prio=5 os_prio=0 cpu=18323.34ms elapsed=235628.48s tid=0x00007f8a04013000 nid=0x75 in Object.wait() [0x00007f895bbfa000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977fac8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #115 daemon prio=5 os_prio=0 cpu=18466.26ms elapsed=235628.48s tid=0x00007f8a14040000 nid=0x76 in Object.wait() [0x00007f895baf9000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977ecf8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #114 daemon prio=5 os_prio=0 cpu=18394.94ms elapsed=235628.48s tid=0x00007f8a3400b800 nid=0x77 in Object.wait() [0x00007f895b9f8000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96e8018> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #124 daemon prio=5 os_prio=0 cpu=18347.78ms elapsed=235628.48s tid=0x00007f8a2c006000 nid=0x78 in Object.wait() [0x00007f895b8f7000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f977d9c8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #123 daemon prio=5 os_prio=0 cpu=18035.61ms elapsed=235628.48s tid=0x00007f8a78005800 nid=0x79 in Object.wait() [0x00007f895b7f6000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9604d30> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #122 daemon prio=5 os_prio=0 cpu=18489.33ms elapsed=235628.48s tid=0x00007f8ab8137000 nid=0x7a in Object.wait() [0x00007f895b6f5000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f95814f8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #95 daemon prio=5 os_prio=0 cpu=17752.84ms elapsed=235628.48s tid=0x00007f8a8800b800 nid=0x7b in Object.wait() [0x00007f895b5f4000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f96040e0> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #121 daemon prio=5 os_prio=0 cpu=18236.84ms elapsed=235628.48s tid=0x00007f8ab0002800 nid=0x7c in Object.wait() [0x00007f895b4f3000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9581998> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #120 daemon prio=5 os_prio=0 cpu=18313.01ms elapsed=235628.48s tid=0x00007f8a68006000 nid=0x7d in Object.wait() [0x00007f895b3f2000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9605980> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "kafka-coordinator-heartbeat-thread | product_spring_aggregator_tunnelstats_groupid_prod" #119 daemon prio=5 os_prio=0 cpu=18082.32ms elapsed=235628.48s tid=0x00007f8a90009000 nid=0x7e in Object.wait() [0x00007f895b2f1000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.4/Native Method) - waiting on at java.lang.Object.wait(java.base@11.0.4/Unknown Source) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:1269) - waiting to re-lock in wait() <0x00000000f9603ab8> (a org.apache.kafka.clients.consumer.internals.ConsumerCoordinator) Locked ownable synchronizers: - None "pool-2-thread-1" #125 prio=5 os_prio=0 cpu=4099.66ms elapsed=235627.64s tid=0x00007f8ad019e800 nid=0x7f runnable [0x00007f895abc2000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.4/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.4/Unknown Source) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.4/Unknown Source) - locked <0x00000000f9c8d078> (a sun.nio.ch.Util$2) - locked <0x00000000f9c8d020> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.4/Unknown Source) at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:343) at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "I/O dispatcher 1" #126 prio=5 os_prio=0 cpu=7234.59ms elapsed=235627.64s tid=0x00007f8920003800 nid=0x80 runnable [0x00007f895aac1000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.4/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.4/Unknown Source) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.4/Unknown Source) - locked <0x00000000f9caccc8> (a sun.nio.ch.Util$2) - locked <0x00000000f9cacc70> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.4/Unknown Source) 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:591) at java.lang.Thread.run(java.base@11.0.4/Unknown Source) Locked ownable synchronizers: - None "Attach Listener" #127 daemon prio=9 os_prio=0 cpu=0.28ms elapsed=0.12s tid=0x00007f8af0001000 nid=0x102a waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE Locked ownable synchronizers: - None "VM Thread" os_prio=0 cpu=101158.03ms elapsed=235637.23s tid=0x00007f8b1c0dd000 nid=0x7 runnable "VM Periodic Task Thread" os_prio=0 cpu=78637.79ms elapsed=235637.17s tid=0x00007f8b1c184800 nid=0xf waiting on condition JNI global refs: 17, weak refs: 0