delta/python-packages/kafka-python.git/test/test_partitioner.py, branch 1.2.2 github.com: mumrah/kafka-python.git add DefaultPartitioner test 2016-01-25T01:33:09+00:00 Dana Powers dana.powers@rd.io 2016-01-25T01:32:29+00:00 4d993bbe12fc20a6469a1e3074a74eabd2aba114 






Fix translation of Java murmur2 code, fix byte encoding for Python 3.
2015-07-29T05:38:28+00:00

Chris Chamberlin
chris.chamberlin@climate.com

2015-07-29T05:38:28+00:00

bb6283df6f9331595020d1d8c28818eeb1131957

Avoid further type changes when Murmur2Partitioner is passed a byte
array.  Change leftover-bytes logic to match the Java switch statement,
and add tests to verify that partition selection matches Java implementation.





Avoid further type changes when Murmur2Partitioner is passed a byte
array.  Change leftover-bytes logic to match the Java switch statement,
and add tests to verify that partition selection matches Java implementation.