summaryrefslogtreecommitdiff
path: root/kafka/protocol/message.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2018-11-13 11:57:45 -0800
committerJeff Widman <jeff@jeffwidman.com>2018-11-18 00:21:18 -0800
commit1d443638e22c2d360086b8d7cee8b5d930741d12 (patch)
tree9e60f53f4a791b306acd6f1a2223557ead1ed750 /kafka/protocol/message.py
parentf3105a434f3bd2fb3f8899e4861e187e786b03da (diff)
downloadkafka-python-1d443638e22c2d360086b8d7cee8b5d930741d12.tar.gz
Be explicit with tuples for %s formatting
Fix #1633
Diffstat (limited to 'kafka/protocol/message.py')
-rw-r--r--kafka/protocol/message.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py
index 19dcbd9..31527bf 100644
--- a/kafka/protocol/message.py
+++ b/kafka/protocol/message.py
@@ -77,7 +77,7 @@ class Message(Struct):
elif version == 0:
fields = (self.crc, self.magic, self.attributes, self.key, self.value)
else:
- raise ValueError('Unrecognized message version: %s' % version)
+ raise ValueError('Unrecognized message version: %s' % (version,))
message = Message.SCHEMAS[version].encode(fields)
if not recalc_crc:
return message
@@ -143,7 +143,7 @@ class Message(Struct):
class PartialMessage(bytes):
def __repr__(self):
- return 'PartialMessage(%s)' % self
+ return 'PartialMessage(%s)' % (self,)
class MessageSet(AbstractType):