summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Collapse)AuthorAgeFilesLines
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-3/+6
|
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-221-2/+6
| | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-222-4/+39
|
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵Dana Powers2016-05-221-17/+61
| | | | messagesets
* Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-222-40/+22
|
* raise ValueError on protocol encode/decode errorsDana Powers2016-05-221-15/+32
|
* * [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
* Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10Dana Powers2016-05-021-0/+22
| | | | check_version
* KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)kafka-2136Dana Powers2016-04-063-9/+48
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-058-62/+181
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-19/+14
|
* Add support for LZ4 compressed messages using python-lz4 moduleDana Powers2016-01-251-3/+12
|
* Support encode and repr on raw BytesIO MessageSets (used in new producer)Dana Powers2016-01-241-0/+12
|
* Add Message and MessageSet HEADER_SIZE bytesDana Powers2016-01-241-0/+2
|
* Message value can be NoneDana Powers2016-01-031-1/+1
|
* Override Message __hash__ to use _encode_self and not recalc crcsDana Powers2016-01-031-0/+3
|
* Assert Message value and (optional) key are bytesDana Powers2016-01-031-0/+2
|
* Add __hash__ method to StructDana Powers2016-01-031-0/+3
|
* Disable pylint errors for py2/py3 compatibility workaroundsDana Powers2016-01-011-2/+2
|
* Struct __eq__Dana Powers2016-01-011-0/+7
|
* Support message decompressionDana Powers2015-12-311-2/+25
|
* Add UNKNOWN_MEMBER_ID to JoinGroupRequestDana Powers2015-12-281-0/+1
|
* Add DEFAULT_GENERATION_ID and DEFAULT_RETENTION_TIME to OffsetCommitRequest_v2Dana Powers2015-12-281-0/+2
|
* Add Message.validate_crc() methodDana Powers2015-12-281-0/+7
|
* Add OffsetResetStrategy enum class to kafka.protocol.offsetDana Powers2015-12-281-0/+5
|
* pylint fixesDana Powers2015-12-101-1/+1
| | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
* Remove KafkaProtocol._decode_messageDana Powers2015-12-101-32/+0
|
* Add pylint hints to AbstractType because we cant mark a classmethod as abstractDana Powers2015-12-101-2/+2
|
* Handle python3 in kafka.protocol.pickleDana Powers2015-12-101-2/+6
|
* 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
* Support pickling of Structs -- _encode_self instance method needs some magicDana Powers2015-12-092-0/+26
|
* Return PartialMessage object in MessageSet.decode if message is truncated by ↵Dana Powers2015-12-091-3/+10
| | | | max_bytes
* Fallback to simple repr() in Schema.repr()Dana Powers2015-12-091-7/+10
|
* Fix BytesIO import in kafka.protocol.messageDana Powers2015-12-091-1/+3
|
* Handle special __init__ signature in Message decode()Dana Powers2015-12-091-0/+8
|
* Handle decoding partial messages in MessageSet - caused by FetchRequest ↵Dana Powers2015-12-091-6/+24
| | | | max_bytes
* few small cleanupsZack Dever2015-12-042-7/+1
|
* administration api schemasZack Dever2015-12-041-0/+44
|
* group membership api schemasZack Dever2015-12-041-0/+108
|
* Add comment re bytes offset tracking in MessageSet decode()Dana Powers2015-12-041-1/+1
|
* Recursive repr, display all field names and values for StructsDana Powers2015-12-044-5/+27
|
* Use simply counting instead of buffer.tell() -- socket.makefile does not ↵Dana Powers2015-12-041-2/+4
| | | | support tell()
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-045-58/+65
|
* Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-0410-371/+461
|
* Fix __init__ legacy relative module importDana Powers2015-12-041-1/+1
|
* 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
|
* Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-042-54/+59
|
* Basic 0.8 Request protocol classes, with encoding onlyDana Powers2015-12-041-0/+355
|
View Lorry Controller Status