summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorBruno Renié <brutasse@gmail.com>2014-08-29 09:53:41 +0200
committerMark Roberts <wizzat@fb.com>2014-09-03 09:55:45 -0700
commitfed41769433d2ae57080d5f7b67f18afc0d9adce (patch)
tree67229d83a3927844cbf5df9fc89f46fc896ee769 /test
parent974cda1b7ad21ae6c2e7f2f03d5f87d8061c143b (diff)
downloadkafka-python-fed41769433d2ae57080d5f7b67f18afc0d9adce.tar.gz
More bytes topics
Diffstat (limited to 'test')
-rw-r--r--test/test_producer.py2
-rw-r--r--test/test_producer_integration.py2
2 files changed, 2 insertions, 2 deletions
diff --git a/test/test_producer.py b/test/test_producer.py
index 184b7ce..523ad40 100644
--- a/test/test_producer.py
+++ b/test/test_producer.py
@@ -15,7 +15,7 @@ class TestKafkaProducer(unittest.TestCase):
def test_producer_message_types(self):
producer = Producer(MagicMock())
- topic = "test-topic"
+ topic = b"test-topic"
partition = 0
bad_data_types = (u'你怎么样?', 12, ['a', 'list'], ('a', 'tuple'), {'a': 'dict'})
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py
index cb96c68..c39d6b5 100644
--- a/test/test_producer_integration.py
+++ b/test/test_producer_integration.py
@@ -9,7 +9,7 @@ from .fixtures import ZookeeperFixture, KafkaFixture
from .testutil import *
class TestKafkaProducerIntegration(KafkaIntegrationTestCase):
- topic = 'produce_topic'
+ topic = b'produce_topic'
@classmethod
def setUpClass(cls): # noqa