Skip to content

Commit 4a1b2f3

Browse files
committed
bugfix: add wakeup parameter back
This was accidentally removed recently due to a cherrypick issue.
1 parent c662d94 commit 4a1b2f3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/admin/client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -379,7 +379,7 @@ def _send_request_to_least_loaded_node(self, request):
379379

380380
return self._client.send(node_id, request)
381381

382-
def _send_request_to_node(self, node_id, request):
382+
def _send_request_to_node(self, node_id, request, wakeup=True):
383383
"""Send a Kafka protocol message to a specific broker.
384384
385385
.. note::

0 commit comments

Comments
 (0)