summaryrefslogtreecommitdiff
path: root/kafka/cluster.py
Commit message (Collapse)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
| | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
* few small cleanupsZack Dever2015-12-041-1/+1
|
* Add simple Cluster class to manage broker metadataDana Powers2015-12-041-0/+91