Clear callback queue without error if explicitly closing fixes #824 (#…

…863)
SOHU-Co · Feb 6, 2018 · d499a1b · d499a1b
1 parent d6f60ec
commit d499a1b
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js
@@ -598,14 +598,14 @@ KafkaClient.prototype.createBroker = function (host, port, longpolling) {
   });
   socket.on('close', function (hadError) {
     self.emit('close', this);
-    if (hadError) {
+    if (!hadError && self.closing) {
+      logger.debug(`clearing ${this.addr} callback queue without error`);
+      self.clearCallbackQueue(this);
+    } else {
       self.clearCallbackQueue(
         this,
         this.error != null ? this.error : new errors.BrokerNotAvailableError('Broker not available')
       );
-    } else {
-      logger.debug(`clearing ${this.addr} callback queue without error`);
-      self.clearCallbackQueue(this);
     }
     retry(this);
   });