diff options
Diffstat (limited to 'test/test_producer.py')
| -rw-r--r-- | test/test_producer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_producer.py b/test/test_producer.py index 9d21369..184b7ce 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -18,13 +18,13 @@ class TestKafkaProducer(unittest.TestCase): topic = "test-topic" partition = 0 - bad_data_types = (u'你怎么样?', 12, ['a','list'], ('a','tuple'), {'a': 'dict'}) + bad_data_types = (u'你怎么样?', 12, ['a', 'list'], ('a', 'tuple'), {'a': 'dict'}) for m in bad_data_types: with self.assertRaises(TypeError): logging.debug("attempting to send message of type %s", type(m)) producer.send_messages(topic, partition, m) - good_data_types = ('a string!',) + good_data_types = (b'a string!',) for m in good_data_types: # This should not raise an exception producer.send_messages(topic, partition, m) |