| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Resolve delayed task futures in KafkaClient.poll | Dana Powers | 2015-12-30 | 1 | -3/+6 | |
| | | ||||||
| * | Remove unused connection_delay method from KafkaClient | Dana Powers | 2015-12-30 | 1 | -18/+0 | |
| | | ||||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -44/+29 | |
| | | ||||||
| * | New async KafkaClient, based on java NetworkClient and ConsumerClient | Dana Powers | 2015-12-28 | 1 | -0/+502 | |
| - Support async client bootstrap retries after exponential backoff - Attempt to finish_connect if still connecting in KafkaClient.ready(node_id) - Run full async loop while waiting for futures in KafkaClient.poll() - Add more fallbacks to KafkaClient.least_loaded_node; worst case, retry boostrap | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |