summaryrefslogtreecommitdiff
path: root/kafka/protocol/produce.py
Commit message (Collapse)AuthorAgeFilesLines
* Add `log_start_offset` to message protocol parsing (#2020)Tincu Gabriel2020-03-251-2/+77
| | | This is in preparation for adding `zstd` support.
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-2/+2
|
* Add Request/Response structs for kafka broker 1.0.0Dana Powers2018-02-061-29/+59
|
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-111-4/+3
| | | | message format
* Protocol updates for 0.11.0.0 (#1127)Dana Powers2017-07-091-2/+35
|
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-7/+22
|
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
|
* Fix ProduceResponse v2 throttle_time_msDana Powers2016-07-171-1/+1
|
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-221-2/+24
|
* KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)kafka-2136Dana Powers2016-04-061-2/+23
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-4/+10
|
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-9/+8
|
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-041-55/+26
|
* Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-041-0/+59