delta/python-packages/kafka-python.git/kafka/partitioner/hashed.py, branch simple github.com: mumrah/kafka-python.git 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.
Use MurmurHash2 for key partition hashing 2015-06-10T20:39:56+00:00 Dana Powers dana.powers@rd.io 2015-05-17T19:28:28+00:00 4e339a746d84650f75fb401e3bd9cfe6e3a65e00 






make partitions arg optional in *Partitioner.partition, defaulting to self.partitions from init
2015-02-09T18:34:19+00:00

Dana Powers
dana.powers@rd.io

2015-02-06T19:57:49+00:00

fb03c69544221a25e925b8c6af45e44ac6944b2a












Separate consumers/producers/partitioners
2014-09-11T05:14:29+00:00

Dana Powers
dana.powers@rd.io

2014-09-09T23:42:23+00:00

27e812e66bd04d3acf59ad6792b07d1c7056c036