summaryrefslogtreecommitdiff
path: root/kafka/coordinator/base.py
Commit message (Expand)AuthorAgeFilesLines
* Ok to sleep in blocking poll for metadata updateDana Powers2016-01-251-1/+1
* Dont need to refresh metadata on GroupCoordinatorNotAvailableErrorsDana Powers2016-01-241-1/+4
* ConsumerCoordinator cleanupsDana Powers2016-01-101-3/+2
* Fix future redefine bug in client.pollDana Powers2016-01-041-0/+1
* Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinatorDana Powers2015-12-301-0/+677