var logstash = new Logstash({ type: 'udp', host: "****", port: "****" }); logstash.send(data, callback); logstash.send open the socket but no method provided to close the connection which leads to lots of open connections.