We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents c662d94 + 4a1b2f3 commit 19ff1f4Copy full SHA for 19ff1f4
kafka/admin/client.py
@@ -379,7 +379,7 @@ def _send_request_to_least_loaded_node(self, request):
379
380
return self._client.send(node_id, request)
381
382
- def _send_request_to_node(self, node_id, request):
+ def _send_request_to_node(self, node_id, request, wakeup=True):
383
"""Send a Kafka protocol message to a specific broker.
384
385
.. note::
0 commit comments