summaryrefslogtreecommitdiff
path: root/test/test_codec.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-06-04 22:10:21 -0700
committerDana Powers <dana.powers@rd.io>2015-06-06 16:22:27 -0700
commit207499b26d5ce6c7a72771250b8e4365944aa1bd (patch)
treedaa38905d6a547ca9e4679253b4fc3c664199866 /test/test_codec.py
parent868115c703afc4403adc8d9481bf31d2c15064dd (diff)
downloadkafka-python-207499b26d5ce6c7a72771250b8e4365944aa1bd.tar.gz
random_string helper should return str not bytes
Diffstat (limited to 'test/test_codec.py')
-rw-r--r--test/test_codec.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/test/test_codec.py b/test/test_codec.py
index 2d7670a..3416fdb 100644
--- a/test/test_codec.py
+++ b/test/test_codec.py
@@ -13,16 +13,16 @@ from test.testutil import random_string
class TestCodec(unittest.TestCase):
def test_gzip(self):
for i in xrange(1000):
- s1 = random_string(100)
- s2 = gzip_decode(gzip_encode(s1))
- self.assertEqual(s1, s2)
+ b1 = random_string(100).encode('utf-8')
+ b2 = gzip_decode(gzip_encode(b1))
+ self.assertEqual(b1, b2)
@unittest.skipUnless(has_snappy(), "Snappy not available")
def test_snappy(self):
for i in xrange(1000):
- s1 = random_string(100)
- s2 = snappy_decode(snappy_encode(s1))
- self.assertEqual(s1, s2)
+ b1 = random_string(100).encode('utf-8')
+ b2 = snappy_decode(snappy_encode(b1))
+ self.assertEqual(b1, b2)
@unittest.skipUnless(has_snappy(), "Snappy not available")
def test_snappy_detect_xerial(self):