summaryrefslogtreecommitdiff
path: root/kafka/coordinator/heartbeat.py
Commit message (Expand)AuthorAgeFilesLines
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-14/+35
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
* Add base coordinator metricsDana Powers2016-07-171-2/+2
* Remove unused importskafka-3318Dana Powers2016-04-051-2/+0
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
* Fixup heartbeat config assertionDana Powers2015-12-311-1/+1
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-3/+3
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-11/+15
* AbstractCoordinator (modelled after upstream Java class)Dana Powers2015-12-281-0/+43