Comparing version 1.15.0-beta.22 to 1.15.0-beta.23
{ | ||
"name": "kafkajs", | ||
"version": "1.15.0-beta.22", | ||
"version": "1.15.0-beta.23", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "28e5be5e292dca853ce075feb242a76df5478a04", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...28e5be5e292dca853ce075feb242a76df5478a04" | ||
"sha": "e2f34ffc8e8e37fc0d31ae51202f1147263cf0ed", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...e2f34ffc8e8e37fc0d31ae51202f1147263cf0ed" | ||
} | ||
} |
@@ -170,4 +170,4 @@ const createRetry = require('../retry') | ||
this.logError(error.message) | ||
this.rejectRequests(error) | ||
await this.disconnect() | ||
this.rejectRequests(error) | ||
reject(error) | ||
@@ -174,0 +174,0 @@ } |