summaryrefslogtreecommitdiff
path: root/kafka/coordinator
Commit message (Collapse)AuthorAgeFilesLines
...
* 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
| | | | | | Avoid printing full errors because they currently include long descriptions that are generally duplicative of our local error message.
* 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
| | | | | | - Use RoundRobinPartitionAssignor by default - Define AbstractPartitionAssignor for custom assignors - metrics still TODO
* AbstractCoordinator (modelled after upstream Java class)Dana Powers2015-12-283-0/+685
- Heartbeat class manages HeartbeatRequest / Response state - metrics are still TODO
View Lorry Controller Status