Skip to content

Commit

Permalink
bugfix: add wakeup parameter back
Browse files Browse the repository at this point in the history
This was accidentally removed recently due to a cherrypick issue.
  • Loading branch information
joelynch committed Mar 11, 2024
1 parent c662d94 commit 4a1b2f3
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kafka/admin/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -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::
Expand Down

0 comments on commit 4a1b2f3

Please sign in to comment.