Encode random_message strings to bytes in test_failover_integration

Author: Dana Powers

test/test_failover_integration.py

@@ -173,7 +173,8 @@ def test_switch_leader_keyed_producer(self):
     def _send_random_messages(self, producer, topic, partition, n):
         for j in range(n):
             logging.debug('_send_random_message to %s:%d -- try %d', topic, partition, j)
-            resp = producer.send_messages(topic, partition, 'msg {0}: {1}'.format(j, random_string(10)))
+            msg = 'msg {0}: {1}'.format(j, random_string(10))
+            resp = producer.send_messages(topic, partition, msg.encode('utf-8'))
             if len(resp) > 0:
                 self.assertEqual(resp[0].error, 0)
             logging.debug('_send_random_message to %s:%d -- try %d success', topic, partition, j)