Return when websocket encounters error and which just causes the defer to fire and close the connection.
Return when websocket encounters error and which just causes the defer to fire and close the connection.

benmanns/kafka-websocket-producer,deckarep/kafka-websocket-consumer