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.
1 parent 20e2d52 commit 512d0a0Copy full SHA for 512d0a0
kafka/consumer/fetcher.py
@@ -661,7 +661,8 @@ def _create_fetch_requests(self):
661
elif not self._client.ready(node_id):
662
# Until we support send request queues, any attempt to send to a not-ready node will be
663
# immediately failed with NodeNotReadyError.
664
- log.debug("Skipping fetch for partition %s because connection to leader node is not ready yet")
+ log.debug("Skipping fetch for partition %s because connection to leader node is not ready yet",
665
+ partition)
666
667
elif node_id in self._nodes_with_pending_fetch_requests:
668
log.debug("Skipping fetch for partition %s because there is a pending fetch request to node %s",
0 commit comments