fix get controller (#1247)

SOHU-Co · Apr 29, 2019 · 9d6d790 · 9d6d790
1 parent ca179f1
commit 9d6d790
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js
@@ -286,7 +286,7 @@ KafkaClient.prototype.getController = function (callback) {
       return callback(new errors.BrokerNotAvailableError('Controller broker not available'));
     }
 
-    return callback(null, broker);
+    return callback(null, broker, this.clusterMetadata.controllerId);
   });
 };