OffsetCommit metadata must be bytes

2014-09-21 20:55:41 -07:00
parent 08df93b3f9
commit 209a8f28e6
1 changed files with 1 additions and 1 deletions
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -514,7 +514,7 @@ class KafkaConsumer(object):

        # API supports storing metadata with each commit
        # but for now it is unused
-        metadata = ''
+        metadata = b''

        offsets = self._offsets.task_done
        commits = []