summaryrefslogtreecommitdiff
path: root/kafka/partitioner.py
Commit message (Collapse)AuthorAgeFilesLines
* Separate consumers/producers/partitionersDana Powers2014-09-101-58/+0
|
* Use built-in next()Bruno ReniƩ2014-09-031-1/+1
|
* Split up and speed up producer based integration testsMark Roberts2014-04-171-0/+1
|
* use NotImplementedError instead of NotImplementedErrorVetoshkin Nikita2013-10-031-1/+1
|
* don't forget to call superclass __init__Vetoshkin Nikita2013-10-031-1/+2
|
* Fix bugs and testingMahendra M2013-06-131-3/+7
| | | | | | * Ensure that round-robin partitioner works fine * _load_metadata_for_topics() would cause duplicate and stale entries in self.topic_partitions. Fix this
* Implement support for Keyed producerMahendra M2013-06-131-0/+52
Provides support for two partitioners * Round robin * Hashed (default as per kafka clients)