summaryrefslogtreecommitdiff
path: root/kafka/producer
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2017-07-07 11:32:25 -0700
committerJeff Widman <jeff@jeffwidman.com>2017-07-07 13:40:31 -0700
commit2f75169504c8bd6f31ab4a88823a8073eb57eced (patch)
treee2c62556e18aaaef4f16ff6b6e1e319509dd414c /kafka/producer
parent43939b29b58d85cef325cb4dba67a413b6f735d8 (diff)
downloadkafka-python-2f75169504c8bd6f31ab4a88823a8073eb57eced.tar.gz
Use logging's built-in string interpolation
Diffstat (limited to 'kafka/producer')
-rw-r--r--kafka/producer/base.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
index 8d067aa..c038bd3 100644
--- a/kafka/producer/base.py
+++ b/kafka/producer/base.py
@@ -217,8 +217,7 @@ def _send_upstream(queue, client, codec, batch_time, batch_size,
else hash(orig_req.messages))
if request_tries or not queue.empty():
- log.error('Stopped producer with {0} unsent messages'
- .format(len(request_tries) + queue.qsize()))
+ log.error('Stopped producer with %d unsent messages', len(request_tries) + queue.qsize())
class Producer(object):