From 4a1b2f3309ac5761fb1baa2c45aa7cf3a34f31dc Mon Sep 17 00:00:00 2001 From: joelynch Date: Mon, 11 Mar 2024 11:49:57 +0100 Subject: [PATCH] bugfix: add wakeup parameter back This was accidentally removed recently due to a cherrypick issue. --- kafka/admin/client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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::