summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Collapse)AuthorAgeFilesLines
* Give better struct errorsbetter-struct-errorsJeff Widman2017-12-071-4/+8
| | | | | | | | | | Stop shadowing the word `error` because we want to know what the specific exception message was. Also give more details on exactly which value failed. We don't know who submitted the value, but perhaps it's unique enough that we can debug it better. Fix #1318
* Fix two bugs in printing bytes instanceAndre Araujo2017-11-271-1/+1
| | | | | | | | | Bug 1: When `value` is None, trying to call `len(None)` throws an exception. Bug 2: When len(`value`) <= 100, the code currently prints b'' rather than `value`.
* Added limit of 100 bytes for Bytes debug printslegacy_records_refactorTaras Voinarovskiy2017-10-141-0/+4
|
* Added minor fixes for PR reviewTaras2017-10-121-1/+2
|
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-114-16/+20
| | | | message format
* Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)Dana Powers2017-10-101-0/+177
|
* 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
|
View Lorry Controller Status