summaryrefslogtreecommitdiff
path: root/kafka/protocol/offset.py
Commit message (Expand)AuthorAgeFilesLines
* Added basic support for offsets_for_times API. Still needs to group by nodes ...Taras Voinarovskiy2017-08-071-1/+3
* Protocol updates for 0.11.0.0 (#1127)Dana Powers2017-07-091-3/+36
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-5/+5
* time --> timestamp to match Java API (#969)Jeff Widman2017-02-031-1/+1
* Add support for offsetRequestV1 messages (#951)Julien Lafaye2017-01-191-3/+32
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-3/+10
* Add OffsetResetStrategy enum class to kafka.protocol.offsetDana Powers2015-12-281-0/+5
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-12/+11
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-041-0/+32