Add kafka for python 3 functional test

Change-Id: I743cd09e3450fac215ff65db37c3fe53e2e43601

.zuul.yaml

@@ -24,6 +24,13 @@
     vars:
       tox_envlist: py35-func-amqp1
 
+- job:
+    name: oslo.messaging-tox-py35-func-kafka
+    parent: openstack-tox-py35
+    vars:
+      tox_envlist: py35-func-kafka
+      bindep_profile: kafka
+
 - job:
     name: oslo.messaging-tox-py35-func-rabbit
     parent: openstack-tox-py35
@@ -227,6 +234,8 @@
         - oslo.messaging-tox-py27-func-rabbit
         - oslo.messaging-tox-py35-func-amqp1:
             voting: false
+        - oslo.messaging-tox-py35-func-kafka:
+            voting: false
         - oslo.messaging-tox-py35-func-rabbit:
             voting: false
 

oslo_messaging/_drivers/impl_kafka.py

@@ -259,7 +259,7 @@ class ProducerConnection(Connection):
         """
         retry = retry if retry >= 0 else None
         message = pack_message(ctxt, msg)
-        message = jsonutils.dumps(message)
+        message = jsonutils.dumps(message).encode('utf-8')
 
         @with_reconnect(retries=retry)
         def wrapped_with_reconnect():

tox.ini

@@ -75,6 +75,13 @@ setenv =
     WORKDIR={toxworkdir}
 commands = {toxinidir}/tools/setup-test-env-amqp1.sh python setup.py testr --slowest --testr-args='{posargs:oslo_messaging.tests.functional}'
 
+[testenv:py35-func-kafka]
+setenv =
+    {[testenv]setenv}
+    TRANSPORT_URL=kafka://127.0.0.1:9092/
+    OS_GROUP_REGEX=oslo_messaging.tests.functional
+commands = {toxinidir}/setup-test-env-kafka.sh python setup.py testr --slowest --testr-args='{posargs:oslo_messaging.tests.functional}'
+
 [testenv:py27-func-zmq]
 basepython = python2.7
 commands = {toxinidir}/setup-test-env-zmq.sh python setup.py testr --slowest --testr-args='{posargs:oslo_messaging.tests.functional}'