| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Add KafkaAdmin class | Richard Lee | 2018-10-24 | 1 | -0/+5 |
| | | | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper. | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 1 | -3/+2 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Added AlterConfigs and DescribeConfigs apis (#1472) | Stephen SORRIAUX | 2018-04-18 | 1 | -1/+96 |
| | | |||||
| * | Fix CreatePartitionsRequest_v0 (#1469) | Stephen SORRIAUX | 2018-04-05 | 1 | -1/+1 |
| | | |||||
| * | Fix error var name in _unpack (#1403) | j2gg0s | 2018-03-05 | 1 | -1/+1 |
| | | | | Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19 | ||||
| * | Fix response schema | Alex Eftimie | 2018-02-20 | 1 | -1/+2 |
| | | |||||
| * | Add Admin CreatePartitions API call | Alex Eftimie | 2018-02-20 | 2 | -1/+32 |
| | | |||||
| * | Use raw in case string overriden (#1373) | Jeff Widman | 2018-02-08 | 1 | -2/+2 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 12 | -27/+27 |
| | | |||||
| * | Add Request/Response structs for kafka broker 1.0.0 | Dana Powers | 2018-02-06 | 5 | -36/+166 |
| | | |||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -1/+1 |
| | | |||||
| * | Minor Exception cleanup | Jeff Widman | 2017-12-12 | 1 | -1/+1 |
| | | |||||
| * | Raise better struct pack/unpack errors (#1320) | Jeff Widman | 2017-12-12 | 1 | -4/+8 |
| | | |||||
| * | Fix two bugs in printing bytes instance | Andre Araujo | 2017-11-27 | 1 | -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_refactor | Taras Voinarovskiy | 2017-10-14 | 1 | -0/+4 |
| | | |||||
| * | Added minor fixes for PR review | Taras | 2017-10-12 | 1 | -1/+2 |
| | | |||||
| * | Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵ | Taras | 2017-10-11 | 4 | -16/+20 |
| | | | | | message format | ||||
| * | Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230) | Dana Powers | 2017-10-10 | 1 | -0/+177 |
| | | |||||
| * | BrokerConnection receive bytes pipe (#1032) | Dana Powers | 2017-08-15 | 2 | -3/+34 |
| | | |||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+3 |
| | | | | | and send in parallel. | ||||
| * | Add private map of api key -> min/max versions to BrokerConnection (#1169) | Dana Powers | 2017-08-06 | 1 | -0/+37 |
| | | |||||
| * | Protocol updates for 0.11.0.0 (#1127) | Dana Powers | 2017-07-09 | 7 | -41/+508 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 8 | -68/+133 |
| | | |||||
| * | Avoid re-encoding for message crc check (#1027) | Dana Powers | 2017-03-13 | 1 | -6/+12 |
| | | |||||
| * | Fix kwarg handing in kafka.protocol.struct.Struct (#1025) | Dana Powers | 2017-03-09 | 1 | -1/+6 |
| | | |||||
| * | Fixed couple of "leaks" when gc is disabled (#979) | Max Baryshnikov | 2017-03-07 | 3 | -15/+24 |
| | | |||||
| * | CreateTopicsRequest / Response v1 (#1012) | Dana Powers | 2017-03-04 | 1 | -3/+34 |
| | | |||||
| * | Add send_list_offset_request for searching offset by timestamp (#1001) | charsyam | 2017-03-02 | 1 | -0/+29 |
| | | |||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 4 | -16/+10 |
| | | |||||
| * | Add MetadataRequest_v2 and MetadataResponse_v2 structures for KIP-78 (#974) | Taras Voinarovskyi | 2017-02-09 | 1 | -2/+34 |
| | | |||||
| * | KIP-88 / KAFKA-3853: OffsetFetch v2 structs (#971) | Jeff Widman | 2017-02-08 | 1 | -2/+30 |
| | | |||||
| * | DRY-up the MetadataRequest_v1 struct (#966) | Jeff Widman | 2017-02-08 | 1 | -4/+5 |
| | | |||||
| * | Add JoinGroup v1 structs (#965) | Jeff Widman | 2017-02-08 | 1 | -2/+25 |
| | | | | The JoinGroupRequest struct added a rebalance_timeout as part of KIP-62 / KAFKA-3888 | ||||
| * | DRY-up the OffsetCommitResponse Structs (#970) | Jeff Widman | 2017-02-03 | 1 | -17/+5 |
| | | |||||
| * | DRY-up the OffsetFetch structs (#964) | Jeff Widman | 2017-02-03 | 1 | -17/+4 |
| | | |||||
| * | time --> timestamp to match Java API (#969) | Jeff Widman | 2017-02-03 | 1 | -1/+1 |
| | | |||||
| * | Add support for offsetRequestV1 messages (#951) | Julien Lafaye | 2017-01-19 | 1 | -3/+32 |
| | | |||||
| * | Add FetchRequest/Response_v3 structs (#943) | Jeff Widman | 2017-01-18 | 1 | -2/+28 |
| | | |||||
| * | Add CreateTopics / DeleteTopics Structs (#944) | Jeff Widman | 2017-01-18 | 1 | -2/+60 |
| | | |||||
| * | Fix message timestamp_type (#828) | Josh Yudaken | 2016-09-15 | 1 | -1/+4 |
| | | |||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -0/+21 |
| | | |||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 12 | -0/+24 |
| | | |||||
| * | Rename partition_assignment -> assignment in MemberMetadata for consistency | Dana Powers | 2016-08-02 | 1 | -1/+1 |
| | | |||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -2/+2 |
| | | |||||
| * | change pickle_method to use python3 special attributes (#777) | John Win | 2016-07-26 | 1 | -3/+9 |
| | | |||||
| * | Fix ProduceResponse v2 throttle_time_ms | Dana Powers | 2016-07-17 | 1 | -1/+1 |
| | | |||||
| * | Always encode size with MessageSet (#771) | Dana Powers | 2016-07-17 | 1 | -3/+1 |
| | | |||||
| * | Add protocol structs for Metadata v1 | Dana Powers | 2016-07-16 | 1 | -4/+36 |
| | | |||||
| * | Add protocol support for null Arrays | Dana Powers | 2016-07-16 | 1 | -0/+6 |
| | | |||||
| * | Add Boolean protocol type | Dana Powers | 2016-07-16 | 1 | -0/+10 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |