com.mongodb.internal.connection.debug.MongoDebuggingException: InternalConnectionDebugger runId=89727b11-9857-4bf6-9d2f-8f9a11f4c006 debuggerId=4 messageSequenceNumber=3, t=2021-08-19T06:10:12.287Z, thread=nioEventLoopGroup-3-2,\u2028Data{openedT=null, openedThreadName=null, connectionDescription=null,\u2028io=IoData{successReads=505, successReadBytes=85889, msgHeaders=251, msgHeaderMessageLengthBytes=85841, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=254, failWrites=0},\u2028streamOperations=OperationData{lastEventIdx=1519,\u2028history=[\u20281518:OperationEvent{mode=a, code=READ, type=B, attachments=[a{IoData{successReads=504, successReadBytes=85873, msgHeaders=251, msgHeaderMessageLengthBytes=85841, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=254, failWrites=0}}]},\u20281519:OperationEvent{mode=a, code=READ, type=S, attachments=[a{IoData{successReads=505, successReadBytes=85889, msgHeaders=251, msgHeaderMessageLengthBytes=85841, failReads=0, failReadBytes=0, failNegativeReads=0, successWrites=254, failWrites=0}}]}\u2028]},\u2028internalConnectionOperations=OperationData{lastEventIdx=750,\u2028history=[\u2028749:OperationEvent{mode=u, code=COMMAND, type=B, attachments=[a{StreamReadPosition{successReadBytes=85873, msgHeaderMessageLengthBytes=85841}}, a{CommandMessageData{id=971, name=aggregate, containsPayload=false, responseExpected=true, namespace=posService.$cmd, speculativeAuthenticate=false}}]},\u2028750:OperationEvent{mode=u, code=DECODE_MESSAGE_HEADER, type=F, attachments=[a{StreamReadPosition{successReadBytes=85889, msgHeaderMessageLengthBytes=85841}}, a{MessageHeader{messageLength=1918985326, requestId=1766072420, responseTo=1851880563, opCode=757097827}}, a{threadName=nioEventLoopGroup-3-2}, a{com.mongodb.internal.connection.debug.MongoDebuggingException: Detected an invalid reply message header MessageHeader{messageLength=1918985326, requestId=1766072420, responseTo=1851880563, opCode=757097827}\u2028 at com.mongodb.internal.connection.debug.InternalConnectionDebugger.invalidMessageHeader(InternalConnectionDebugger.java:113)\u2028 at com.mongodb.internal.connection.MessageHeader.(MessageHeader.java:50)\u2028 at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:641)\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.onResult(InternalStreamConnection.java:644)\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: com.mongodb.MongoInternalException: The reply message length 1918985326 is greater than the maximum message length 48000000\u2028 at com.mongodb.internal.connection.MessageHeader.(MessageHeader.java:47)\u2028 ... 132 more\u2028}]}\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.failed(InternalConnectionDebugger.java:613) at com.mongodb.internal.connection.debug.InternalConnectionDebugger.invalidMessageHeader(InternalConnectionDebugger.java:114) at com.mongodb.internal.connection.MessageHeader.(MessageHeader.java:50) at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:641) at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:627) at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:522) at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:519) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:815) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:809) at com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:232) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.readAsync(InternalConnectionDebugger.java:809) at com.mongodb.internal.connection.InternalStreamConnection.readAsync(InternalStreamConnection.java:519) at com.mongodb.internal.connection.InternalStreamConnection.access$1100(InternalStreamConnection.java:81) at com.mongodb.internal.connection.InternalStreamConnection$2.onResult(InternalStreamConnection.java:384) at com.mongodb.internal.connection.InternalStreamConnection$2.onResult(InternalStreamConnection.java:373) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:476) at com.mongodb.internal.connection.InternalStreamConnection$3.completed(InternalStreamConnection.java:473) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$2.completed(InternalConnectionDebugger.java:791) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$2.completed(InternalConnectionDebugger.java:785) at com.mongodb.connection.netty.NettyStream$2.operationComplete(NettyStream.java:187) at com.mongodb.connection.netty.NettyStream$2.operationComplete(NettyStream.java:181) at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577) at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551) at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490) at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:183) at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95) at io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30) at com.mongodb.connection.netty.NettyStream.writeAsync(NettyStream.java:181) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream.writeAsync(InternalConnectionDebugger.java:785) 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.AggregateOperationImpl.executeAsync(AggregateOperationImpl.java:196) at com.mongodb.internal.operation.ChangeStreamOperation.executeAsync(ChangeStreamOperation.java:335) at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$5.call(AsyncChangeStreamBatchCursor.java:233) at com.mongodb.internal.operation.OperationHelper.withAsyncConnectionSource(OperationHelper.java:606) at com.mongodb.internal.operation.OperationHelper.access$100(OperationHelper.java:62) at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithSourceCallback.onResult(OperationHelper.java:585) at com.mongodb.internal.operation.OperationHelper$AsyncCallableWithSourceCallback.onResult(OperationHelper.java:575) 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:553) at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.retryOperation(AsyncChangeStreamBatchCursor.java:225) at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor.access$500(AsyncChangeStreamBatchCursor.java:40) at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:214) at com.mongodb.internal.operation.AsyncChangeStreamBatchCursor$4.onResult(AsyncChangeStreamBatchCursor.java:206) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:369) at com.mongodb.internal.operation.AsyncQueryBatchCursor$CommandResultSingleResultCallback.onResult(AsyncQueryBatchCursor.java:347) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor$2.onResult(DefaultServer.java:248) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.connection.CommandProtocolImpl$1.onResult(CommandProtocolImpl.java:82) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection$2.onResult(DefaultConnectionPool.java:517) at com.mongodb.internal.connection.UsageTrackingInternalConnection$2.onResult(UsageTrackingInternalConnection.java:111) at com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:48) at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:389) at com.mongodb.internal.connection.InternalStreamConnection$2$1.onResult(InternalStreamConnection.java:384) at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:644) at com.mongodb.internal.connection.InternalStreamConnection$MessageHeaderCallback.onResult(InternalStreamConnection.java:627) at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:522) at com.mongodb.internal.connection.InternalStreamConnection$5.completed(InternalStreamConnection.java:519) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:815) at com.mongodb.internal.connection.debug.InternalConnectionDebugger$DebuggableStream$3.completed(InternalConnectionDebugger.java:809) at com.mongodb.connection.netty.NettyStream.readAsync(NettyStream.java:232) at com.mongodb.connection.netty.NettyStream.handleReadResponse(NettyStream.java:262) at com.mongodb.connection.netty.NettyStream.access$800(NettyStream.java:69) at com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:321) at com.mongodb.connection.netty.NettyStream$InboundBufferHandler.channelRead0(NettyStream.java:318) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:99) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:714) at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:650) at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:576) at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493) at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) Caused by: com.mongodb.internal.connection.debug.MongoDebuggingException: Detected an invalid reply message header MessageHeader{messageLength=1918985326, requestId=1766072420, responseTo=1851880563, opCode=757097827} at com.mongodb.internal.connection.debug.InternalConnectionDebugger.invalidMessageHeader(InternalConnectionDebugger.java:113) ... 133 common frames omitted Caused by: com.mongodb.MongoInternalException: The reply message length 1918985326 is greater than the maximum message length 48000000 at com.mongodb.internal.connection.MessageHeader.(MessageHeader.java:47) ... 132 common frames omitted