summaryrefslogtreecommitdiff
path: root/kafka/protocol/legacy.py
Commit message (Collapse)AuthorAgeFilesLines
* 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