diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index dfbb0d6..eb85060 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -496,7 +496,7 @@ class Fetcher(six.Iterator): self.config['max_partition_fetch_bytes'] ) fetchable[node_id][partition.topic].append(partition_info) - log.debug("Adding fetch request for partition %d at offset %d", + log.debug("Adding fetch request for partition %s at offset %d", partition, position) requests = {} |