Fixes #569 producer recover from broker going down

SOHU-Co · Jan 31, 2017 · 925d477 · 925d477
1 parent 74d3d2a
commit 925d477
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/baseProducer.js b/lib/baseProducer.js
@@ -83,7 +83,12 @@ BaseProducer.prototype.connect = function () {
     }
   });
   this.client.on('brokersChanged', function () {
-    this.topicMetadata = {};
+    let topics = Object.keys(this.topicMetadata);
+    this.refreshMetadata(topics, function (error) {
+      if (error) {
+        self.emit(error);
+      }
+    });
   });
   this.client.on('error', function (err) {
     self.emit('error', err);