summaryrefslogtreecommitdiff
path: root/kafka/coordinator/base.py
Commit message (Expand)AuthorAgeFilesLines
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-161-0/+9
* Avoid some exceptions in Coordinator.__del__ (#668)Dana Powers2016-04-251-1/+2
* Changing some commented out metrics to avoid future gotchas.Zack Dever2016-04-131-3/+3
* Default sleep=True in client.pollDana Powers2016-04-081-1/+1
* Can no longer have coordinator_id if coordinator_unknown()Dana Powers2016-04-081-6/+0
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-15/+14
* KAFKA-3318: clean up consumer logging and error messagesDana Powers2016-04-051-36/+42
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
* Improve Coordinator Error handlingDana Powers2016-04-041-8/+14
* Log successful heartbeat as INFO; improve heartbeat response loggingDana Powers2016-03-121-11/+12
* HeartbeatTask should reschedule heartbeat on coordinator_unknown()Dana Powers2016-03-121-2/+6
* break up some circular references and close client wake pipe on __del__aisch2016-02-161-1/+11
* 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