_send_request_to_controller returns a raw result, not a future

TylerLubeck · jeffwidman · commit 6e2978edee9a · 2020-02-06T14:20:40.000-08:00
diff --git a/kafka/admin/client.py b/kafka/admin/client.py
@@ -493,12 +493,12 @@ def _get_cluster_metadata(self, topics=None, auto_topic_creation=False, use_cont
             )
 
         if use_controller:
-            future = self._send_request_to_controller(request)
-        else:
-            future = self._send_request_to_node(
-                self._client.least_loaded_node(),
-                request
-            )
+            return self._send_request_to_controller(request)
+
+        future = self._send_request_to_node(
+            self._client.least_loaded_node(),
+            request
+        )
         self._wait_for_futures([future])
         return future.value
 
