Merge pull request #29 from aiven/joelynch/wakeup

bugfix: add wakeup parameter back
aiven · Mar 11, 2024 · 19ff1f4 · 19ff1f4
2 parents c662d94 + 4a1b2f3
commit 19ff1f4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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::