summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--test/test_producer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_producer.py b/test/test_producer.py
index 297b265..e681e43 100644
--- a/test/test_producer.py
+++ b/test/test_producer.py
@@ -50,7 +50,7 @@ class TestKafkaProducer(unittest.TestCase):
client.get_partition_ids_for_topic.return_value = [0, 1]
producer = KeyedProducer(client)
topic = b"test-topic"
- key = 'testkey'
+ key = b"testkey"
bad_data_types = (u'你怎么样?', 12, ['a', 'list'],
('a', 'tuple'), {'a': 'dict'},)