_send_request_to_controller returns a raw result, not a future

dpkp · Feb 6, 2020 · 6e2978e · 6e2978e
1 parent f92889a
commit 6e2978e
Showing 1 changed file with 6 additions and 6 deletions.
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