Make all unit tests pass on py3.3/3.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)