fix #1449 : check controllerMetadata is not null

SOHU-Co · Jun 28, 2021 · e7f6472 · e7f6472
1 parent fcc8aef
commit e7f6472
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js
@@ -279,7 +279,10 @@ KafkaClient.prototype.getController = function (callback) {
     var controllerId = result[1].clusterMetadata.controllerId;
     var controllerMetadata = result[0][controllerId];
 
-    var broker = this.getBroker(controllerMetadata.host, controllerMetadata.port);
+    var broker;
+    if(controllerMetadata) {
+      broker = this.getBroker(controllerMetadata.host, controllerMetadata.port);
+    }
 
     if (!broker || !broker.isConnected()) {
       this.refreshBrokerMetadata();