[dspeterson]

There is a dedicated thread for monitoring the socket so clients don't block trying to write. In case of transient load spike or slowness in Kafka, the bulk of the queueing should occur inside the daemon, where you can see queue lengths via web interface. God luck with your project :-)