summaryrefslogtreecommitdiff
path: root/kafka/coordinator/consumer.py
Commit message (Expand)AuthorAgeFilesLines
...
* Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinatorDana Powers2015-12-301-2/+2
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-14/+5
* More Docstring ImprovementsDana Powers2015-12-301-2/+33
* Make group_id a Coordinator kwarg (not arg) for consistencyDana Powers2015-12-301-2/+2
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-27/+31
* Fix log statement bug (via pylint)Dana Powers2015-12-291-1/+1
* Clean more ConsumerCoordinator docstringsDana Powers2015-12-291-16/+19
* Dont warn in AutoCommitTask.disable if not previously scheduledDana Powers2015-12-291-1/+1
* Improve OffsetCommit error loggingDana Powers2015-12-291-23/+33
* Improve various docstringsDana Powers2015-12-291-13/+21
* Remove extra raise and old TODO comment in coordinatorsDana Powers2015-12-291-1/+1
* Remove recursive client.poll call in ConsumerCoordinatorDana Powers2015-12-291-2/+3
* Pass auto commit parameters from KafkaConsumer to ConsumerCoordinatorDana Powers2015-12-291-1/+1
* ConsumerCoordinator (based on upstream Java client)Dana Powers2015-12-281-0/+605
View Lorry Controller Status