diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-10 16:02:40 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-10 16:02:40 -0800 |
| commit | 1eaad6fcbef499c522f45361972e7ee9e8a78909 (patch) | |
| tree | 09978d86a48b80aaa7a8b5589487b00e14142b49 | |
| parent | 7ee73df4c4bb3c69ac38accc30ff68bc6d64d594 (diff) | |
| download | kafka-python-1eaad6fcbef499c522f45361972e7ee9e8a78909.tar.gz | |
Fix debug logging call in PR 500
| -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 = {} |