com.mongodb.internal.connection.debug.MongoDebuggingException: InternalConnectionDebugger runId=e463422c-2a4f-46bd-b551-1495c86947cd debuggerId=4 messageSequenceNumber=3, t=2021-08-19T06:16:52.714Z, thread=boundedElastic-1,\u2028Data{openedT=null, openedThreadName=null, connectionDescription=null,\u2028io=IoData{successReads=569, successReadBytes=97419, msgHeaders=285, msgHeaderMessageLengthBytes=-804944549, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=286, failWrites=0},\u2028streamOperations=OperationData{lastEventIdx=1714,\u2028history=[\u20281713:OperationEvent{mode=a, code=READ, type=B, attachments=[a{IoData{successReads=569, successReadBytes=97419, msgHeaders=285, msgHeaderMessageLengthBytes=-804944549, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=286, failWrites=0}}]},\u20281714:OperationEvent{mode=a, code=WRITE, type=B, attachments=[a{IoData{successReads=569, successReadBytes=97419, msgHeaders=285, msgHeaderMessageLengthBytes=-804944549, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=286, failWrites=0}}]}\u2028]},\u2028internalConnectionOperations=OperationData{lastEventIdx=848,\u2028history=[\u2028847:OperationEvent{mode=u, code=COMMAND, type=F, attachments=[a{StreamReadPosition{successReadBytes=97419, msgHeaderMessageLengthBytes=-804944549}}, a{CommandMessageData{id=1074, name=aggregate, containsPayload=false, responseExpected=true, namespace=posService.$cmd, speculativeAuthenticate=false}}, a{threadName=nioEventLoopGroup-3-1}, a{com.mongodb.MongoInternalException: Unexpected runtime exception\u2028 at com.mongodb.internal.connection.InternalStreamConnection.translateReadException(InternalStreamConnection.java:579)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:532)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.access$1100(InternalStreamConnection.java:81)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:642)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:627)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:522)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:519)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:815)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:809)\u2028 at com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:232)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.readAsync(InternalConnectionDebugger.java:809)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:519)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.access$1100(InternalStreamConnection.java:81)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$2.onResult(InternalStreamConnection.java:384)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$2.onResult(InternalStreamConnection.java:373)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:476)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:473)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$2.completed(InternalConnectionDebugger.java:791)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$2.completed(InternalConnectionDebugger.java:785)\u2028 at com.mongodb.connection.netty.NettyStream$2.operationComplete(NettyStream.java:187)\u2028 at com.mongodb.connection.netty.NettyStream$2.operationComplete(NettyStream.java:181)\u2028 at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)\u2028 at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)\u2028 at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)\u2028 at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:183)\u2028 at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)\u2028 at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)\u2028 at com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:181)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.writeAsync(InternalConnectionDebugger.java:785)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:473)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:469)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.sendCommandMessageAsync(InternalStreamConnection.java:373)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:342)\u2028 at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:114)\u2028 at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:511)\u2028 at com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:77)\u2028 at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:239)\u2028 at com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:218)\u2028 at com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:135)\u2028 at com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:126)\u2028 at com.mongodb.internal.operation.CommandOperationHelper.executeCommandAsyncWithConnection(CommandOperationHelper.java:451)\u2028 at com.mongodb.internal.operation.CommandOperationHelper$8.call(CommandOperationHelper.java:415)\u2028 at com.mongodb.internal.operation.OperationHelper$7.onResult(OperationHelper.java:613)\u2028 at com.mongodb.internal.operation.OperationHelper$7.onResult(OperationHelper.java:610)\u2028 at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:114)\u2028 at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:103)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:201)\u2028 at com.mongodb.internal.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:156)\u2028 at com.mongodb.internal.connection.DefaultServer.getConnectionAsync(DefaultServer.java:103)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:131)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding$SessionBindingAsyncConnectionSource.getConnection(ClientSessionBinding.java:140)\u2028 at com.mongodb.internal.operation.OperationHelper.withAsyncConnectionSource(OperationHelper.java:610)\u2028 at com.mongodb.internal.operation.OperationHelper.access$200(OperationHelper.java:62)\u2028 at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:630)\u2028 at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:618)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:208)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:196)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:105)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:99)\u2028 at com.mongodb.internal.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:428)\u2028 at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:299)\u2028 at com.mongodb.internal.connection.BaseCluster.selectServerAsync(BaseCluster.java:155)\u2028 at com.mongodb.internal.connection.AbstractMultiServerCluster.selectServerAsync(AbstractMultiServerCluster.java:54)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:99)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:84)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding.getReadConnectionSource(ClientSessionBinding.java:58)\u2028 at com.mongodb.internal.operation.OperationHelper.withAsyncReadConnection(OperationHelper.java:557)\u2028 at com.mongodb.internal.operation.CommandOperationHelper.executeCommandAsync(CommandOperationHelper.java:409)\u2028 at com.mongodb.internal.operation.AggregateOperationImpl.executeAsync(AggregateOperationImpl.java:196)\u2028 at com.mongodb.internal.operation.ChangeStreamOperation.executeAsync(ChangeStreamOperation.java:335)\u2028 at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$5.call(AsyncChangeStreamBatchCursor.java:233)\u2028 at com.mongodb.internal.operation.OperationHelper.withAsyncConnectionSource(OperationHelper.java:606)\u2028 at com.mongodb.internal.operation.OperationHelper.access$100(OperationHelper.java:62)\u2028 at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithSourceCallback.onResult(OperationHelper.java:585)\u2028 at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithSourceCallback.onResult(OperationHelper.java:575)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:208)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:196)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:105)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:99)\u2028 at com.mongodb.internal.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:428)\u2028 at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:299)\u2028 at com.mongodb.internal.connection.BaseCluster.selectServerAsync(BaseCluster.java:155)\u2028 at com.mongodb.internal.connection.AbstractMultiServerCluster.selectServerAsync(AbstractMultiServerCluster.java:54)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:99)\u2028 at com.mongodb.internal.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:84)\u2028 at com.mongodb.internal.async.client.ClientSessionBinding.getReadConnectionSource(ClientSessionBinding.java:58)\u2028 at com.mongodb.internal.operation.OperationHelper.withAsyncReadConnection(OperationHelper.java:553)\u2028 at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.retryOperation(AsyncChangeStreamBatchCursor.java:225)\u2028 at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.access$500(AsyncChangeStreamBatchCursor.java:40)\u2028 at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:214)\u2028 at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:206)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:369)\u2028 at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:347)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$2.onResult(DefaultServer.java:248)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.connection.CommandProtocolImpl$1.onResult(CommandProtocolImpl.java:82)\u2028 at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection$2.onResult(DefaultConnectionPool.java:517)\u2028 at com.mongodb.internal.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:111)\u2028 at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:389)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:384)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:662)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback$MessageCallback.onResult(InternalStreamConnection.java:652)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:532)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.access$1100(InternalStreamConnection.java:81)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:642)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:627)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:522)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:519)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:815)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:809)\u2028 at com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:232)\u2028 at com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:262)\u2028 at com.mongodb.connection.netty.NettyStream.access$800(NettyStream.java:69)\u2028 at com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:321)\u2028 at com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:318)\u2028 at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99)\u2028 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\u2028 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\u2028 at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)\u2028 at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410)\u2028 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)\u2028 at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)\u2028 at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919)\u2028 at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)\u2028 at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714)\u2028 at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650)\u2028 at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576)\u2028 at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)\u2028 at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)\u2028 at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)\u2028 at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)\u2028 at java.lang.Thread.run(Thread.java:748)\u2028Caused by: java.lang.IllegalArgumentException: minimumReadableBytes: -16 (expected: >= 0)\u2028 at io.netty.util.internal.ObjectUtil.checkPositiveOrZero(ObjectUtil.java:66)\u2028 at io.netty.buffer.AbstractByteBuf.checkReadableBytes(AbstractByteBuf.java:1464)\u2028 at io.netty.buffer.AbstractByteBuf.readSlice(AbstractByteBuf.java:881)\u2028 at com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:214)\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.readAsync(InternalConnectionDebugger.java:809)\u2028 at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:519)\u2028 ... 137 more\u2028}]},\u2028848:OperationEvent{mode=u, code=COMMAND, type=B, attachments=[a{StreamReadPosition{successReadBytes=97419, msgHeaderMessageLengthBytes=-804944549}}, a{CommandMessageData{id=1076, name=buildInfo, containsPayload=false, responseExpected=true, namespace=posService.$cmd, speculativeAuthenticate=false}}]}\u2028]}\u2028} at com.mongodb.internal.connection.debug.InternalConnectionDebugger.exception(InternalConnectionDebugger.java:171) at com.mongodb.internal.connection.debug.InternalConnectionDebugger.report(InternalConnectionDebugger.java:148) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DataCollector$OperationCollector.started(InternalConnectionDebugger.java:581) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.startedWrite(InternalConnectionDebugger.java:887) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.writeAsync(InternalConnectionDebugger.java:782) at com.mongodb.internal.connection.InternalStreamConnection.writeAsync(InternalStreamConnection.java:473) at com.mongodb.internal.connection.InternalStreamConnection.sendMessageAsync(InternalStreamConnection.java:469) at com.mongodb.internal.connection.InternalStreamConnection.sendCommandMessageAsync(InternalStreamConnection.java:373) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:342) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:114) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:511) at com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:77) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:239) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:218) at com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:135) at com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:126) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandAsyncWithConnection(CommandOperationHelper.java:451) at com.mongodb.internal.operation.CommandOperationHelper$8.call(CommandOperationHelper.java:415) at com.mongodb.internal.operation.OperationHelper$7.onResult(OperationHelper.java:613) at com.mongodb.internal.operation.OperationHelper$7.onResult(OperationHelper.java:610) at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:114) at com.mongodb.internal.connection.DefaultServer$1.onResult(DefaultServer.java:103) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.connection.DefaultConnectionPool.openAsync(DefaultConnectionPool.java:201) at com.mongodb.internal.connection.DefaultConnectionPool.getAsync(DefaultConnectionPool.java:156) at com.mongodb.internal.connection.DefaultServer.getConnectionAsync(DefaultServer.java:103) at com.mongodb.internal.binding.AsyncClusterBinding$AsyncClusterBindingConnectionSource.getConnection(AsyncClusterBinding.java:131) at com.mongodb.internal.async.client.ClientSessionBinding$SessionBindingAsyncConnectionSource.getConnection(ClientSessionBinding.java:140) at com.mongodb.internal.operation.OperationHelper.withAsyncConnectionSource(OperationHelper.java:610) at com.mongodb.internal.operation.OperationHelper.access$200(OperationHelper.java:62) at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:630) at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithConnectionAndSourceCallback.onResult(OperationHelper.java:618) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:208) at com.mongodb.internal.async.client.ClientSessionBinding$WrappingCallback.onResult(ClientSessionBinding.java:196) at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:105) at com.mongodb.internal.binding.AsyncClusterBinding$1.onResult(AsyncClusterBinding.java:99) at com.mongodb.internal.connection.BaseCluster$ServerSelectionRequest.onResult(BaseCluster.java:428) at com.mongodb.internal.connection.BaseCluster.handleServerSelectionRequest(BaseCluster.java:299) at com.mongodb.internal.connection.BaseCluster.selectServerAsync(BaseCluster.java:155) at com.mongodb.internal.connection.AbstractMultiServerCluster.selectServerAsync(AbstractMultiServerCluster.java:54) at com.mongodb.internal.binding.AsyncClusterBinding.getAsyncClusterBindingConnectionSource(AsyncClusterBinding.java:99) at com.mongodb.internal.binding.AsyncClusterBinding.getReadConnectionSource(AsyncClusterBinding.java:84) at com.mongodb.internal.async.client.ClientSessionBinding.getReadConnectionSource(ClientSessionBinding.java:58) at com.mongodb.internal.operation.OperationHelper.withAsyncReadConnection(OperationHelper.java:557) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandAsync(CommandOperationHelper.java:409) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandAsync(CommandOperationHelper.java:389) at com.mongodb.internal.operation.CommandReadOperation.executeAsync(CommandReadOperation.java:63) at com.mongodb.internal.async.client.OperationExecutorImpl$1$1.onResult(OperationExecutorImpl.java:86) at com.mongodb.internal.async.client.OperationExecutorImpl$1$1.onResult(OperationExecutorImpl.java:74) at com.mongodb.internal.async.client.OperationExecutorImpl.getReadWriteBinding(OperationExecutorImpl.java:182) at com.mongodb.internal.async.client.OperationExecutorImpl.access$200(OperationExecutorImpl.java:43) at com.mongodb.internal.async.client.OperationExecutorImpl$1.onResult(OperationExecutorImpl.java:72) at com.mongodb.internal.async.client.OperationExecutorImpl$1.onResult(OperationExecutorImpl.java:66) at com.mongodb.internal.async.client.ClientSessionHelper.createClientSession(ClientSessionHelper.java:63) at com.mongodb.internal.async.client.ClientSessionHelper.withClientSession(ClientSessionHelper.java:53) at com.mongodb.internal.async.client.OperationExecutorImpl.execute(OperationExecutorImpl.java:66) at com.mongodb.internal.async.client.AsyncMongoDatabaseImpl.executeCommand(AsyncMongoDatabaseImpl.java:241) at com.mongodb.internal.async.client.AsyncMongoDatabaseImpl.runCommand(AsyncMongoDatabaseImpl.java:206) at com.mongodb.internal.async.client.AsyncMongoDatabaseImpl.runCommand(AsyncMongoDatabaseImpl.java:200) at com.mongodb.reactivestreams.client.internal.MongoDatabaseImpl.lambda$runCommand$0(MongoDatabaseImpl.java:123) at com.mongodb.reactivestreams.client.internal.SingleResultCallbackSubscription.requestInitialData(SingleResultCallbackSubscription.java:39) at com.mongodb.reactivestreams.client.internal.AbstractSubscription.tryRequestInitialData(AbstractSubscription.java:177) at com.mongodb.reactivestreams.client.internal.AbstractSubscription.request(AbstractSubscription.java:100) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribeInner(MonoFlatMapMany.java:143) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onSubscribe(MonoFlatMapMany.java:237) at com.mongodb.reactivestreams.client.internal.SingleResultCallbackSubscription.(SingleResultCallbackSubscription.java:34) at com.mongodb.reactivestreams.client.internal.Publishers.lambda$publish$1(Publishers.java:69) at reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onNext(MonoFlatMapMany.java:188) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:61) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:97) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onError(FluxFilterFuseable.java:156) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onError(FluxMapFuseable.java:326) at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onNext(FluxHandleFuseable.java:185) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2344) at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:243) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.request(FluxMapFuseable.java:346) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.request(FluxFilterFuseable.java:184) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:103) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onSubscribe(FluxFilterFuseable.java:81) at reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onSubscribe(FluxMapFuseable.java:255) at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:148) at reactor.core.publisher.MonoCurrentContext.subscribe(MonoCurrentContext.java:35) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:418) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:267) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:225) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:363) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:112) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2344) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.request(FluxFilterFuseable.java:184) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:103) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onSubscribe(FluxFilterFuseable.java:81) at reactor.core.publisher.MonoCurrentContext.subscribe(MonoCurrentContext.java:35) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:203) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:203) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onNext(MonoIgnoreThen.java:296) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247) at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:173) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2344) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.request(MonoPeekTerminal.java:132) at reactor.core.publisher.MonoZip$ZipInner.onSubscribe(MonoZip.java:318) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onSubscribe(MonoPeekTerminal.java:145) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:153) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:274) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:851) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onNext(MonoPeekTerminal.java:173) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2344) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.request(MonoPeekTerminal.java:132) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2152) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2026) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90) at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onSubscribe(MonoPeekTerminal.java:145) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:441) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:211) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:141) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:92) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:274) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:851) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144) at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107) at reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:535) at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:999) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107) at reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:480) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:413) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:267) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:225) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:363) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:418) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:267) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:225) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:363) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:441) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:211) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:78) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2346) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2152) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2026) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54) at reactor.core.publisher.Mono.subscribe(Mono.java:4213) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75) at reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160) at reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:838) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:600) at reactor.core.publisher.FluxFlatMap$FlatMapMain.drain(FluxFlatMap.java:580) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onComplete(FluxFlatMap.java:457) at reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:289) at reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:225) at reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:363) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:161) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:86) at reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:64) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1782) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onComplete(FluxDefaultIfEmpty.java:100) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136) at reactor.core.publisher.FluxFilter$FilterSubscriber.onComplete(FluxFilter.java:160) at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:262) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1783) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.signalCached(MonoCacheTime.java:320) at reactor.core.publisher.MonoCacheTime$CoordinatorSubscriber.onNext(MonoCacheTime.java:337) at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:249) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68) at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: com.mongodb.internal.connection.debug.MongoDebuggingException: Detected either concurrent usage or usage after error, eventIdx=1714, mode=a, code=WRITE, type=B at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DataCollector$OperationCollector.registerEvent(InternalConnectionDebugger.java:647) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DataCollector$OperationCollector.started(InternalConnectionDebugger.java:577) ... 250 common frames omitted