From 127f34c40007c0a6e2dae7eee87acfb3972831a8 Mon Sep 17 00:00:00 2001 From: Alexandre Feblot Date: Tue, 15 Jul 2025 17:28:12 +0200 Subject: [PATCH] Add missing argument in debug log --- kafka/consumer/fetcher.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index d57bc4786..8e524790c 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -661,7 +661,8 @@ def _create_fetch_requests(self): elif not self._client.ready(node_id): # Until we support send request queues, any attempt to send to a not-ready node will be # immediately failed with NodeNotReadyError. - 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", + partition) elif node_id in self._nodes_with_pending_fetch_requests: log.debug("Skipping fetch for partition %s because there is a pending fetch request to node %s",