Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinator | Dana Powers | 2015-12-30 | 1 | -2/+2 | |
| | ||||||
* | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -14/+5 | |
| | ||||||
* | More Docstring Improvements | Dana Powers | 2015-12-30 | 1 | -2/+33 | |
| | ||||||
* | Make group_id a Coordinator kwarg (not arg) for consistency | Dana Powers | 2015-12-30 | 1 | -2/+2 | |
| | ||||||
* | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -27/+31 | |
| | ||||||
* | Fix log statement bug (via pylint) | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | ||||||
* | Clean more ConsumerCoordinator docstrings | Dana Powers | 2015-12-29 | 1 | -16/+19 | |
| | ||||||
* | Dont warn in AutoCommitTask.disable if not previously scheduled | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | ||||||
* | Improve OffsetCommit error logging | Dana Powers | 2015-12-29 | 1 | -23/+33 | |
| | | | | | | Avoid printing full errors because they currently include long descriptions that are generally duplicative of our local error message. | |||||
* | Improve various docstrings | Dana Powers | 2015-12-29 | 1 | -13/+21 | |
| | ||||||
* | Remove extra raise and old TODO comment in coordinators | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | ||||||
* | Remove recursive client.poll call in ConsumerCoordinator | Dana Powers | 2015-12-29 | 1 | -2/+3 | |
| | ||||||
* | Pass auto commit parameters from KafkaConsumer to ConsumerCoordinator | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | ||||||
* | ConsumerCoordinator (based on upstream Java client) | Dana Powers | 2015-12-28 | 1 | -0/+605 | |
- Use RoundRobinPartitionAssignor by default - Define AbstractPartitionAssignor for custom assignors - metrics still TODO |