summaryrefslogtreecommitdiff
path: root/kafka/consumer/fetcher.py
Commit message (Collapse)AuthorAgeFilesLines
...
* New class: kafka.consumer.fetcher.FetcherDana Powers2015-12-281-0/+523
- manages fetch requests via async client and subscription_state - based on upstream java client