summaryrefslogtreecommitdiff
path: root/test/test_fetcher.py
Commit message (Expand)AuthorAgeFilesLines
* Added `max_bytes` option and FetchRequest_v3 usage. (#962)Taras Voinarovskyi2017-03-061-1/+2
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-4/+2
* KAFKA-3007: KafkaConsumer max_poll_records (#831)Dana Powers2016-09-281-14/+2
* Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-041-1/+1
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-1/+1
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-221-1/+14
* instrument metrics for fetch requestsZack Dever2016-04-131-1/+2
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-11/+13
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-3/+2
* Add Fetcher unit testsDana Powers2016-01-251-0/+101