delta/python-packages/kafka-python.git/kafka/protocol/fetch.py, branch 2.0.2

Add logic for inferring newer broker versions (#2038)

2020-05-05T11:29:23+00:00

* 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)

2018-02-06T20:10:45+00:00

Add Request/Response structs for kafka broker 1.0.0

2018-02-06T19:39:48+00:00

Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format

2017-10-11T15:09:17+00:00

Protocol updates for 0.11.0.0 (#1127)

2017-07-09T15:04:39+00:00

Derive all api classes from Request / Response base classes (#1030)

2017-03-14T20:34:37+00:00

PEP-8: Spacing & removed unused imports (#899)

2017-02-09T20:27:16+00:00

Add FetchRequest/Response_v3 structs (#943)

2017-01-19T00:52:29+00:00

Always absolute_import

2016-08-03T04:36:00+00:00

Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)

2016-05-22T19:41:17+00:00