Bytes in self.msg()

2 files changed, 2 insertions, 2 deletions

diff --git a/kafka/producer.py b/kafka/producer.py
index fb83da6..687bb2d 100644
--- a/kafka/producer.py
+++ b/kafka/producer.py
@@ -180,7 +180,7 @@ class Producer(object):
 
         # Raise TypeError if any message is not encoded as bytes
         if any(not isinstance(m, six.binary_type) for m in msg):
-            raise TypeError("all produce message payloads must be type str")
+            raise TypeError("all produce message payloads must be type bytes")
 
         if self.async:
             for m in msg:
diff --git a/test/testutil.py b/test/testutil.py
index 7c8c802..114dff9 100644
--- a/test/testutil.py
+++ b/test/testutil.py
@@ -88,7 +88,7 @@ class KafkaIntegrationTestCase(unittest.TestCase):
         if s not in self._messages:
             self._messages[s] = '%s-%s-%s' % (s, self.id(), str(uuid.uuid4()))
 
-        return self._messages[s]
+        return self._messages[s].encode('utf-8')
 
 class Timer(object):
     def __enter__(self):