summaryrefslogtreecommitdiff
path: root/kafka/coordinator/base.py
Commit message (Expand)AuthorAgeFilesLines
* Fix possible request draining in ensure_active_group (#896)Dana Powers2016-12-021-3/+6
* Always include an error for logging when the coordinator is marked dead (#890)Dana Powers2016-11-181-7/+7
* Drain pending requests to the coordinator before initiating group rejoin (#798)Dana Powers2016-08-041-0/+8
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...Dana Powers2016-08-041-4/+4
* Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-041-2/+3
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* Add base coordinator metricsDana Powers2016-07-171-70/+71
* 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