summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex <chekunkov@gmail.com>2017-03-03 18:13:26 +0000
committerDana Powers <dana.powers@gmail.com>2017-03-03 10:13:26 -0800
commitb1f22b882a338a3456ca88782e05660cffff72f6 (patch)
tree817bb8af2144e65f6d2fc9f580344ee8f2f06614
parent861b9e9b6516d94c2f932651b8baa7fb5ed9bd0b (diff)
downloadkafka-python-b1f22b882a338a3456ca88782e05660cffff72f6.tar.gz
Replace %s with %r in producer debug log message (#973)
-rw-r--r--kafka/producer/kafka.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 5581f63..338a57a 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -505,7 +505,7 @@ class KafkaProducer(object):
tp = TopicPartition(topic, partition)
if timestamp_ms is None:
timestamp_ms = int(time.time() * 1000)
- log.debug("Sending (key=%s value=%s) to %s", key, value, tp)
+ log.debug("Sending (key=%r value=%r) to %s", key, value, tp)
result = self._accumulator.append(tp, timestamp_ms,
key_bytes, value_bytes,
self.config['max_block_ms'])