summaryrefslogtreecommitdiff
path: root/kafka/coordinator
Commit message (Expand)AuthorAgeFilesLines
* Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_nodeDana Powers2016-03-131-0/+4
* 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
* Mock client.ready() call to test coordinator offset fetch requestDana Powers2016-02-191-1/+2
* Some attributes may not exist in __del__ if we failed assertionsDana Powers2016-02-181-1/+1
* More friendly warning when offset fetch request returns unknown topic / parti...Dana Powers2016-02-181-1/+2
* Verify node ready before sending offset fetch request from coordinatorDana Powers2016-02-181-0/+5
* break up some circular references and close client wake pipe on __del__aisch2016-02-162-6/+21
* Add RangePartitionAssignor (and use as default); add assignor testsrange_assignorDana Powers2016-02-164-4/+98
* Fixup: _send_offset_commit_request future should succeed w/ True, not NoneDana Powers2016-02-021-1/+2
* Ok to sleep in blocking poll for metadata updateDana Powers2016-01-251-1/+1
* Disable offset commits and auto-partition-assignment when group_id is NoneDana Powers2016-01-241-8/+17
* Dont need to refresh metadata on GroupCoordinatorNotAvailableErrorsDana Powers2016-01-241-1/+4
* KAFKA-2978: consumer stops fetching when consumed and fetch positions get out...Dana Powers2016-01-101-1/+2
* ConsumerCoordinator cleanupsDana Powers2016-01-102-13/+36
* Move ConsumerProtocol definition to kafka.coordinator.protocolDana Powers2016-01-103-35/+44
* Fix future redefine bug in client.pollDana Powers2016-01-041-0/+1
* Drop unused method from ConsumerCoordinatorDana Powers2016-01-031-5/+0
* Check api_version in ConsumerCoordinatorDana Powers2016-01-031-32/+94
* Use python3 compatible next() in roundrobin assignorDana Powers2016-01-011-2/+2
* Fixup heartbeat config assertionDana Powers2015-12-311-1/+1
* Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinatorDana Powers2015-12-302-5/+5
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-303-21/+8
* Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handlerDana Powers2015-12-301-0/+3
* More Docstring ImprovementsDana Powers2015-12-303-30/+106
* Rename KafkaClient.connection_failed -> is_disconnectedDana Powers2015-12-301-1/+1
* Make group_id a Coordinator kwarg (not arg) for consistencyDana Powers2015-12-302-7/+5
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-293-55/+63
* 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
* Log request failures in AbstractCoordinator._failed_requestDana Powers2015-12-291-5/+10
* _handle_group_coordinator_response should resolve future with the coordinator idDana Powers2015-12-291-1/+1
* Improve heartbeat loggingDana Powers2015-12-291-14/+13
* Log as INFO: group join, leader election, partition assignmentsDana Powers2015-12-291-1/+4
* Improve various docstringsDana Powers2015-12-292-19/+33
* Remove extra raise and old TODO comment in coordinatorsDana Powers2015-12-292-2/+1
* Make more methods private(ish) in AbstractCoordinatorDana Powers2015-12-291-13/+13
* 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
* Fix HeartbeatTask request_in_flight handlingDana Powers2015-12-291-1/+1
* ConsumerCoordinator (based on upstream Java client)Dana Powers2015-12-284-0/+703
* AbstractCoordinator (modelled after upstream Java class)Dana Powers2015-12-283-0/+685
View Lorry Controller Status