summaryrefslogtreecommitdiff
path: root/kafka/cluster.py
Commit message (Expand)AuthorAgeFilesLines
* Add available_partitions_for_topic() and partitions_for_broker()Dana Powers2016-01-231-2/+23
* Improve cluster.ttl() readabilityDana Powers2016-01-101-3/+7
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-8/+12
* Add ClusterMetadata.add_group_coordinator()Dana Powers2015-12-281-0/+39
* Rename Cluster -> ClusterMetadata; align with upstream Metadata classDana Powers2015-12-281-66/+121
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-1/+1
* few small cleanupsZack Dever2015-12-041-1/+1
* Add simple Cluster class to manage broker metadataDana Powers2015-12-041-0/+91