summaryrefslogtreecommitdiff
path: root/kafka/protocol/fetch.py
Commit message (Collapse)AuthorAgeFilesLines
* Add logic for inferring newer broker versions (#2038)Tincu Gabriel2020-05-051-2/+180
| | | | | | | | | | | | | | * Add logic for inferring newer broker versions - New Fetch / ListOffsets request / response objects - Add new test cases to inferr code based on mentioned objects - Add unit test to check inferred version against whatever resides in KAFKA_VERSION - Add new kafka broker versions to integration list - Add more kafka broker versions to travis task list - Add support for broker version 2.5 id * Implement PR change requests: fewer versions for travis testing, remove unused older versions for inference code, remove one minor version from known server list Do not use newly created ACL request / responses in allowed version lists, due to flexible versions enabling in kafka actually requiring a serialization protocol header update Revert admin client file change
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-2/+2
|
* Add Request/Response structs for kafka broker 1.0.0Dana Powers2018-02-061-2/+26
|
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-111-6/+5
| | | | message format
* Protocol updates for 0.11.0.0 (#1127)Dana Powers2017-07-091-5/+89
|
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-9/+9
|
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-1/+1
|
* Add FetchRequest/Response_v3 structs (#943)Jeff Widman2017-01-181-2/+28
|
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
|
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-221-2/+15
|
* KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)kafka-2136Dana Powers2016-04-061-2/+24
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-3/+9
|
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-11/+13
|
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-041-0/+30