summaryrefslogtreecommitdiff
path: root/test/testutil.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/testutil.py')
-rw-r--r--test/testutil.py2
1 files changed, 1 insertions, 1 deletions
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):