summaryrefslogtreecommitdiff
path: root/kafka/protocol
Commit message (Expand)AuthorAgeFilesLines
* Fix response error checking in KafkaAdminClient send_to_controlleradmin_client_unpack_errorsDana Powers2018-11-231-1/+1
* Add protocols for {Describe,Create,Delete} AclsUlrik Johansson2018-11-191-0/+185
* Be explicit with tuples for %s formattingJeff Widman2018-11-183-4/+4
* Pre-compile pack/unpack function callsbillyevans2018-10-291-13/+29
* Add KafkaAdmin classRichard Lee2018-10-241-0/+5
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-051-3/+2
* Added AlterConfigs and DescribeConfigs apis (#1472)Stephen SORRIAUX2018-04-181-1/+96
* Fix CreatePartitionsRequest_v0 (#1469)Stephen SORRIAUX2018-04-051-1/+1
* Fix error var name in _unpack (#1403)j2gg0s2018-03-051-1/+1
* Fix response schemaAlex Eftimie2018-02-201-1/+2
* Add Admin CreatePartitions API callAlex Eftimie2018-02-202-1/+32
* Use raw in case string overriden (#1373)Jeff Widman2018-02-081-2/+2
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-0612-27/+27
* Add Request/Response structs for kafka broker 1.0.0Dana Powers2018-02-065-36/+166
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-1/+1
* Minor Exception cleanupJeff Widman2017-12-121-1/+1
* Raise better struct pack/unpack errors (#1320)Jeff Widman2017-12-121-4/+8
* Fix two bugs in printing bytes instanceAndre Araujo2017-11-271-1/+1
* 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 me...Taras2017-10-114-16/+20
* 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
* 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
* 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
View Lorry Controller Status