Comparing version 1.15.0-beta.19 to 1.15.0-beta.20
{ | ||
"name": "kafkajs", | ||
"version": "1.15.0-beta.19", | ||
"version": "1.15.0-beta.20", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "3bd245d31f10acf83c91cba00e8cbb983947add5", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...3bd245d31f10acf83c91cba00e8cbb983947add5" | ||
"sha": "a46d2a09b09d1cb3b57d8b5bce805f1e871208fd", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...a46d2a09b09d1cb3b57d8b5bce805f1e871208fd" | ||
} | ||
} |
@@ -158,4 +158,4 @@ const createRetry = require('../retry') | ||
this.logError(error.message, { stack: e.stack }) | ||
this.rejectRequests(error) | ||
await this.disconnect() | ||
this.rejectRequests(error) | ||
@@ -162,0 +162,0 @@ reject(error) |