summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
Commit message (Expand)AuthorAgeFilesLines
* Add metadata_max_age_ms and retry_backoff_ms options to async clientDana Powers2016-01-071-0/+8
* Fix future redefine bug in client.pollDana Powers2016-01-041-3/+3
* Catch py3 ConnectionErrorsDana Powers2016-01-031-3/+9
* Add KafkaClient.check_version() to guess broker versionDana Powers2016-01-031-0/+52
* Fix bug in _initiate_connect preventing reconnect to 'bootstrap'Dana Powers2016-01-031-3/+3
* sys.maxint not supported in python3Dana Powers2016-01-011-4/+3
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-7/+7
* More Docstring ImprovementsDana Powers2015-12-301-60/+131
* Fix blacked_out typo in least_loaded_nodeDana Powers2015-12-301-1/+1
* Rename KafkaClient.connection_failed -> is_disconnectedDana Powers2015-12-301-1/+1
* Improve removed tasks handing in DelayedTaskQueue.pop_readyDana Powers2015-12-301-2/+5
* Remove unnecessary calls in KafkaClient._pollDana Powers2015-12-301-13/+13
* Resolve delayed task futures in KafkaClient.pollDana Powers2015-12-301-3/+6
* Remove unused connection_delay method from KafkaClientDana Powers2015-12-301-18/+0
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-44/+29
* New async KafkaClient, based on java NetworkClient and ConsumerClientDana Powers2015-12-281-0/+502