summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Collapse)AuthorAgeFilesLines
* BrokerConnection receive bytes pipe (#1032)Dana Powers2017-08-152-3/+34
|
* Added basic support for offsets_for_times API. Still needs to group by nodes ↵Taras Voinarovskiy2017-08-071-1/+3
| | | | and send in parallel.
* Add private map of api key -> min/max versions to BrokerConnection (#1169)Dana Powers2017-08-061-0/+37
|
* Protocol updates for 0.11.0.0 (#1127)Dana Powers2017-07-097-41/+508
|
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-148-68/+133
|
* Avoid re-encoding for message crc check (#1027)Dana Powers2017-03-131-6/+12
|
* Fix kwarg handing in kafka.protocol.struct.Struct (#1025)Dana Powers2017-03-091-1/+6
|
* Fixed couple of "leaks" when gc is disabled (#979)Max Baryshnikov2017-03-073-15/+24
|
* CreateTopicsRequest / Response v1 (#1012)Dana Powers2017-03-041-3/+34
|
* 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-094-16/+10
|
* Add MetadataRequest_v2 and MetadataResponse_v2 structures for KIP-78 (#974)Taras Voinarovskyi2017-02-091-2/+34
|
* KIP-88 / KAFKA-3853: OffsetFetch v2 structs (#971)Jeff Widman2017-02-081-2/+30
|
* DRY-up the MetadataRequest_v1 struct (#966)Jeff Widman2017-02-081-4/+5
|
* Add JoinGroup v1 structs (#965)Jeff Widman2017-02-081-2/+25
| | | The JoinGroupRequest struct added a rebalance_timeout as part of KIP-62 / KAFKA-3888
* DRY-up the OffsetCommitResponse Structs (#970)Jeff Widman2017-02-031-17/+5
|
* DRY-up the OffsetFetch structs (#964)Jeff Widman2017-02-031-17/+4
|
* 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
|
* Add FetchRequest/Response_v3 structs (#943)Jeff Widman2017-01-181-2/+28
|
* Add CreateTopics / DeleteTopics Structs (#944)Jeff Widman2017-01-181-2/+60
|
* Fix message timestamp_type (#828)Josh Yudaken2016-09-151-1/+4
|
* implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-031-0/+21
|
* Always absolute_importabsolute_importDana Powers2016-08-0212-0/+24
|
* Rename partition_assignment -> assignment in MemberMetadata for consistencyDana Powers2016-08-021-1/+1
|
* Vendor six 1.10.0sixDana Powers2016-08-011-2/+2
|
* change pickle_method to use python3 special attributes (#777)John Win2016-07-261-3/+9
|
* Fix ProduceResponse v2 throttle_time_msDana Powers2016-07-171-1/+1
|
* Always encode size with MessageSet (#771)Dana Powers2016-07-171-3/+1
|
* Add protocol structs for Metadata v1Dana Powers2016-07-161-4/+36
|
* Add protocol support for null ArraysDana Powers2016-07-161-0/+6
|
* Add Boolean protocol typeDana Powers2016-07-161-0/+10
|
* 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
|
View Lorry Controller Status