summaryrefslogtreecommitdiff
path: root/kafka/protocol/legacy.py
Commit message (Expand)AuthorAgeFilesLines
* Be explicit with tuples for %s formattinguse-explicit-tuples-for-stringsJeff Widman2018-11-171-1/+1
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-051-3/+2
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...Taras2017-10-111-2/+4
* Fixed couple of "leaks" when gc is disabled (#979)Max Baryshnikov2017-03-071-12/+17
* Add send_list_offset_request for searching offset by timestamp (#1001)charsyam2017-03-021-0/+29
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-9/+5
* Vendor six 1.10.0sixDana Powers2016-08-011-2/+2
* Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-221-3/+5
* * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ...Paul Cavallaro2016-05-101-2/+12
* KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)kafka-2136Dana Powers2016-04-061-5/+1
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-8/+8
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-19/+14
* Remove KafkaProtocol._decode_messageDana Powers2015-12-101-32/+0
* Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-82/+46
* Change KafkaProtocol to encode/decode Structs, not bytesDana Powers2015-12-091-246/+106
* Switch crc32 back to signed integer -- this is consistent with protocol encod...Dana Powers2015-12-041-2/+2
* Fix tests broken by legacy module moveDana Powers2015-12-041-0/+2
* Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-041-0/+646