Message Sending Failure Due to SocketException

[dormanze]

Hi,everyone.
The following error message is displayed on the client:

Caused by: java.net.SocketException: Broken pipe
    at java.net.SocketOutputStream.socketWrite0(Native Method) ~[?:1.8.0_73]
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109) ~[?:1.8.0_73]
    at java.net.SocketOutputStream.write(SocketOutputStream.java:153) ~[?:1.8.0_73]

The server reports the following error:

{writer,send_failed,{error,timeout}}

My channel is reused, so I suspect that consumers take too long to consume messages.
I read related cases because the prefetchCount parameter is not enabled. As a result, the server pushes messages to the client at a faster speed than the client consumption. As a result, the TCP of the client is full and the connection is disconnected.
But the problem is that I have enabled this parameter, but I still have problems.

I don't know if it's because my prefetchCount parameter is too large or for other reasons.

[dormanze]

The prefetch count parameter applies only to the manual ACK scenario. The automatic ACK parameter does not take effect. If automatic ACK is set, the processing time is slow for consumers to process messages synchronously. As a result, the message generation speed of producers is much higher than the message consumption speed of consumers. As a result, the buffer of the channel is full. The solution is to change the ACK mode of the consumer to manual ACK and enable the prefetch count parameter, speed up the message processing speed of the consumer, or process messages asynchronously.