diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py index af59e7e..069ad06 100644 --- 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 = []