diff options
| author | Tyler Lubeck <tyler@coffeemeetsbagel.com> | 2020-02-06 13:41:45 -0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2020-02-06 14:20:40 -0800 |
| commit | 6e2978edee9a06e9dbe60afcac226b27b83cbc74 (patch) | |
| tree | 42d4525a114f0cf7471656dcda50abc117452fc7 | |
| parent | f92889af79db08ef26d89cb18bd48c7dd5080010 (diff) | |
| download | kafka-python-6e2978edee9a06e9dbe60afcac226b27b83cbc74.tar.gz | |
_send_request_to_controller returns a raw result, not a future
| -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 |