diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 62d487543..69e643dc7 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -379,7 +379,7 @@ def _send_request_to_least_loaded_node(self, request): return self._client.send(node_id, request) - def _send_request_to_node(self, node_id, request): + def _send_request_to_node(self, node_id, request, wakeup=True): """Send a Kafka protocol message to a specific broker. .. note::