Add test for murmur2 py2 bytes bug

This commit is contained in:
Dana Powers
2016-08-24 10:01:45 -07:00
parent 7d31aa3978
commit a60e71af16

View File

@@ -3,6 +3,7 @@ import six
from kafka.partitioner import Murmur2Partitioner
from kafka.partitioner.default import DefaultPartitioner
from kafka.partitioner.hashed import murmur2
def test_default_partitioner():
@@ -41,3 +42,9 @@ def test_murmur2_java_compatibility():
assert p.partition(b'abc') == 107
assert p.partition(b'123456789') == 566
assert p.partition(b'\x00 ') == 742
def test_murmur2_not_ascii():
# Verify no regression of murmur2() bug encoding py2 bytes that dont ascii encode
murmur2(b'\xa4')
murmur2(b'\x81' * 1000)