summaryrefslogtreecommitdiff
path: root/kafka/protocol/legacy.py
Commit message (Collapse)AuthorAgeFilesLines
* 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
| | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages
* 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
| | | | | - add Payload to kafka.common Request/Responses namedtuples - OffsetFetch and OffsetCommit still need to be converted
* Switch crc32 back to signed integer -- this is consistent with protocol ↵Dana Powers2015-12-041-2/+2
| | | | encoding spec
* Fix tests broken by legacy module moveDana Powers2015-12-041-0/+2
|
* Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-041-0/+646