summaryrefslogtreecommitdiff
path: root/kafka/coordinator/base.py
Commit message (Expand)AuthorAgeFilesLines
* Handle lookup_coordinator send failures (#1279)Dana Powers2017-10-241-5/+11
* KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-111-4/+19
* Use for join-time-max and sync-time-max metrics Max() measure function (#1146)Alexey Pervushin2017-07-201-2/+2
* Backoff on unavailable group coordinator retry (#1125)Dana Powers2017-06-191-0/+2
* Additional docstrings for autocommit close optionDana Powers2017-03-131-2/+2
* Short-circuit group coordinator requests when NodeNotReady (#995)Dana Powers2017-03-091-0/+23
* Avoid unknown coordinator after client poll (#1023)Dana Powers2017-03-091-7/+6
* For 0.8.2, only attempt connection to coordinator if least_loaded_node succeedsDana Powers2017-03-071-1/+2
* Minor additional logging for consumer coordinatorDana Powers2017-03-061-0/+2
* Dont refresh metadata on failed group coordinator request unless needed (#1006)Dana Powers2017-03-031-6/+4
* Add sphinx formatting to hyperlink methods (#898)Jeff Widman2017-03-031-5/+5
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-6/+6
* 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