RabbitMQ.Client.Exceptions.AlreadyClosedException

[Abhishek D]

Unhandled exception. RabbitMQ.Client.Exceptions.AlreadyClosedException: Already closed: The AMQP operation was interrupted: AMQP close-reason, initiated by Library, code=541, text='Unexpected Exception', classId=0, methodId=0, cause=System.IO.IOException: Unable to read data from the transport connection: Connection reset by peer.  
---> System.Net.Sockets.SocketException (104): Connection reset by peer  
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 size)  
--- End of inner exception stack trace ---  
at RabbitMQ.Client.Impl.InboundFrame.ReadFrom(NetworkBinaryReader reader)  
at RabbitMQ.Client.Framing.Impl.Connection.MainLoopIteration()  
at RabbitMQ.Client.Framing.Impl.Connection.MainLoop()  
at RabbitMQ.Client.Impl.SessionBase.Transmit(Command cmd)  
at Microsoft.Azure.WebJobs.Extensions.RabbitMQ.RabbitMQListener.<>c__DisplayClass20_0.<b__0>d.MoveNext()  
--- End of stack trace from previous location where exception was thrown ---  
at System.Threading.Tasks.Task.<>c.b__139_1(Object state)  
at System.Threading.QueueUserWorkItemCallbackDefaultContext.Execute()  
at System.Threading.ThreadPoolWorkQueue.Dispatch()  
at System.Threading._ThreadPoolWaitCallback.PerformWaitCallback()

I am using Azure Functions rabbitmq trigger on K8S to listen the queue messages. It works well for load around 5k messages but gives the above error on 10K messages that too few time.