fix: create internal queue for serialized sending to socket
(fix kafka-411 : Broken Pipe)