Tcp.Received is not called on high load where as Tcp.Connected is being called

Akka Libraries
2

See if you can use Akka Streams IO instead. It’s built on top Akka IO but provides backpressure in an easier way, which is probably what is wrong with your attempt.