delta/python-packages/kafka-python.git/kafka/partitioner, branch warn_dns_error

Sort partitions before calling partitioner (#905)

2016-12-19T19:26:03+00:00

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

Always absolute_import

2016-08-03T04:36:00+00:00

Vendor six 1.10.0

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

DefaultPartitioner - implements java client logic

2016-01-24T21:26:42+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

Add Sphinx API docs

2015-01-15T23:01:40+00:00