summaryrefslogtreecommitdiff
path: root/test/test_conn.py
diff options
context:
space:
mode:
authorBruno ReniƩ <brutasse@gmail.com>2014-08-28 20:50:20 +0200
committerMark Roberts <wizzat@fb.com>2014-09-03 09:55:44 -0700
commitcf0b7f0530e765f2cf710bd35daf53bb4ea205d2 (patch)
treef38669f145112a7f301691f311b3c8aca51d1f59 /test/test_conn.py
parent83af5102e995e854a1980b90f1400afdd098da37 (diff)
downloadkafka-python-cf0b7f0530e765f2cf710bd35daf53bb4ea205d2.tar.gz
Make all unit tests pass on py3.3/3.4
Diffstat (limited to 'test/test_conn.py')
-rw-r--r--test/test_conn.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/test/test_conn.py b/test/test_conn.py
index bc644d7..ce02401 100644
--- a/test/test_conn.py
+++ b/test/test_conn.py
@@ -13,8 +13,8 @@ class ConnTest(unittest.TestCase):
'host': 'localhost',
'port': 9090,
'request_id': 0,
- 'payload': 'test data',
- 'payload2': 'another packet'
+ 'payload': b'test data',
+ 'payload2': b'another packet'
}
# Mocking socket.create_connection will cause _sock to always be a
@@ -35,12 +35,12 @@ class ConnTest(unittest.TestCase):
struct.pack('>%ds' % payload_size, self.config['payload']),
struct.pack('>i', payload2_size),
struct.pack('>%ds' % payload2_size, self.config['payload2']),
- ''
+ b''
]
# Create a connection object
self.conn = KafkaConnection(self.config['host'], self.config['port'])
-
+
# Reset any mock counts caused by __init__
self.MockCreateConn.reset_mock()