delta/python-packages/kafka-python.git/kafka/partitioner/hashed.py, branch fetch_partition_compressed_offset

Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)

2016-10-22T16:48:08+00:00

* Add test for murmur2 py2 bytes bug
* Fix murmur2 handling of python2 bytes
* Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported
* Make DefaultPartitioner importable from kafka.partitioner

Update Partitioners for use with KafkaProducer (#827)

2016-09-28T17:30:32+00:00

Vendor six 1.10.0

2016-08-01T21:47:40+00:00

Fix translation of Java murmur2 code, fix byte encoding for Python 3.

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

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

make partitions arg optional in *Partitioner.partition, defaulting to self.partitions from init

2015-02-09T18:34:19+00:00

Separate consumers/producers/partitioners

2014-09-11T05:14:29+00:00