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 5cdebb3..980a683 100644
--- a/test/testutil.py
+++ b/test/testutil.py
@@ -59,7 +59,7 @@ class KafkaIntegrationTestCase(unittest.TestCase):
return
if not self.topic:
- self.topic = "%s-%s" % (self.id()[self.id().rindex(".") + 1:], random_string(10))
+ self.topic = "%s-%s" % (self.id()[self.id().rindex(".") + 1:], random_string(10).decode('utf-8'))
if self.create_client:
self.client = KafkaClient('%s:%d' % (self.server.host, self.server.port))