summaryrefslogtreecommitdiff
path: root/kafka/cluster.py
Commit message (Expand)AuthorAgeFilesLines
* Add ClusterMetadata documentationDana Powers2017-03-071-0/+14
* Drop old brokers when rebuilding broker metadata (#1005)Dana Powers2017-03-031-3/+6
* Metadata with_partitions() (#787)Dana Powers2016-08-011-1/+20
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1Dana Powers2016-07-161-6/+37
* Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-161-8/+11
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-201-0/+4
* Remove unused importskafka-3318Dana Powers2016-04-051-1/+0
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
* Improve kafka.cluster docstringsDana Powers2016-02-161-7/+65
* Add lock to synchronize metadata updates and future handlingDana Powers2016-02-151-18/+34
* warn (not error) on LeaderNotAvailable - this is usually not cause for concernDana Powers2016-02-151-2/+2
* Update ClusterMetadata commentsDana Powers2016-02-151-7/+7
* Track set of unauthorized_topics in ClusterMetadataDana Powers2016-02-151-0/+3
* Remove unused cluster._version private attributeDana Powers2016-02-151-4/+1
* Keep full PartitionMetadata from MetadataResponsesDana Powers2016-02-151-6/+10
* Implement KafkaConsumer.topics()Dana Powers2016-02-011-2/+4
* 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