Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Separate consumers/producers/partitioners | Dana Powers | 2014-09-10 | 1 | -58/+0 |
| | |||||
* | Use built-in next() | Bruno ReniƩ | 2014-09-03 | 1 | -1/+1 |
| | |||||
* | Split up and speed up producer based integration tests | Mark Roberts | 2014-04-17 | 1 | -0/+1 |
| | |||||
* | use NotImplementedError instead of NotImplementedError | Vetoshkin Nikita | 2013-10-03 | 1 | -1/+1 |
| | |||||
* | don't forget to call superclass __init__ | Vetoshkin Nikita | 2013-10-03 | 1 | -1/+2 |
| | |||||
* | Fix bugs and testing | Mahendra M | 2013-06-13 | 1 | -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 producer | Mahendra M | 2013-06-13 | 1 | -0/+52 |
Provides support for two partitioners * Round robin * Hashed (default as per kafka clients) |