openstack/deb-python-kafka
Code Issues Proposed changes

Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported

Browse Source
This commit is contained in:
Dana Powers
2016-08-24 12:33:10 -07:00
parent 546f4f530a
commit 0cb1f1be70
1 changed files with 0 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/test_partitioner.py
View File

@@ -23,16 +23,6 @@ def test_default_partitioner():
assert partitioner(None, all_partitions, []) in all_partitions
def test_hash_bytes():
p = Murmur2Partitioner(range(1000))
assert p.partition(bytearray(b'test')) == p.partition(b'test')
def test_hash_encoding():
p = Murmur2Partitioner(range(1000))
assert p.partition('test') == p.partition(u'test')
def test_murmur2_java_compatibility():
p = Murmur2Partitioner(range(1000))
# compare with output from Kafka's org.apache.kafka.clients.producer.Partitioner