summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBruno ReniƩ <brutasse@gmail.com>2014-08-28 22:36:38 +0200
committerBruno ReniƩ <brutasse@gmail.com>2014-08-28 22:36:38 +0200
commit71e14cb5cb4ce4efc19987e15e15a811a01f43a2 (patch)
tree1dbd113a8894f6e7d08f9cbc0517670bf2a3d4e8
parent083984724a59d38704f7f2afe9d2e81183f2cfca (diff)
downloadkafka-python-71e14cb5cb4ce4efc19987e15e15a811a01f43a2.tar.gz
Topic in bytes
-rw-r--r--test/testutil.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/testutil.py b/test/testutil.py
index 8584509..5cdebb3 100644
--- a/test/testutil.py
+++ b/test/testutil.py
@@ -64,7 +64,7 @@ class KafkaIntegrationTestCase(unittest.TestCase):
if self.create_client:
self.client = KafkaClient('%s:%d' % (self.server.host, self.server.port))
- self.client.ensure_topic_exists(self.topic)
+ self.client.ensure_topic_exists(self.topic.encode('utf-8'))
self._messages = {}