Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Add available_partitions_for_topic() and partitions_for_broker() | Dana Powers | 2016-01-23 | 1 | -2/+23 |
| | |||||
* | Improve cluster.ttl() readability | Dana Powers | 2016-01-10 | 1 | -3/+7 |
| | |||||
* | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -8/+12 |
| | |||||
* | Add ClusterMetadata.add_group_coordinator() | Dana Powers | 2015-12-28 | 1 | -0/+39 |
| | |||||
* | Rename Cluster -> ClusterMetadata; align with upstream Metadata class | Dana Powers | 2015-12-28 | 1 | -66/+121 |
| | |||||
* | Switch BrokerConnection to (mostly) non-blocking IO. | Dana Powers | 2015-12-17 | 1 | -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 cleanups | Zack Dever | 2015-12-04 | 1 | -1/+1 |
| | |||||
* | Add simple Cluster class to manage broker metadata | Dana Powers | 2015-12-04 | 1 | -0/+91 |