diff options
| -rw-r--r-- | kafka/admin/client.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 454c5b3..f71d9ef 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -493,12 +493,12 @@ class KafkaAdminClient(object): ) 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 |