Comparing version 2.2.0-beta.1 to 2.2.0-beta.2
{ | ||
"name": "kafkajs", | ||
"version": "2.2.0-beta.1", | ||
"version": "2.2.0-beta.2", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -85,5 +85,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "a0ef9556f89e638c2fc26ccf2fa47be44a3fb7bc", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v2.1.0...a0ef9556f89e638c2fc26ccf2fa47be44a3fb7bc" | ||
"sha": "8a799c61830b2889df10816511ffd3a0caba2445", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v2.1.0...8a799c61830b2889df10816511ffd3a0caba2445" | ||
} | ||
} |
@@ -12,3 +12,6 @@ const KEEP_ALIVE_DELAY = 60000 // in ms | ||
const socket = ssl | ||
? tls.connect(Object.assign({ host, port, servername: host }, ssl), onConnect) | ||
? tls.connect( | ||
Object.assign({ host, port }, !net.isIP(host) ? { servername: host } : {}, ssl), | ||
onConnect | ||
) | ||
: net.connect({ host, port }, onConnect) | ||
@@ -15,0 +18,0 @@ |
730077
21273