fix #1449 : check controllerMetadata is not null

SOHU-Co · Jun 28, 2021 · 2f82437 · 2f82437
1 parent fcc8aef
commit 2f82437
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js
@@ -279,7 +279,7 @@ 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 = controllerMetadata ? this.getBroker(controllerMetadata.host, controllerMetadata.port) : null;
 
     if (!broker || !broker.isConnected()) {
       this.refreshBrokerMetadata();