| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Core Protocol: Add support for flexible versions (#2151) | Tincu Gabriel | 2020-12-02 | 1 | -1/+90 |
| | | | | | | | | - Add support for new request and response headers, supporting flexible versions / tagged fields - Add List / Alter partition reassignments APIs - Add support for varints - Add support for compact collections (byte array, string, array) | ||||
| * | Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162) | Lourens Naudé | 2020-11-15 | 1 | -1/+41 |
| | | | | | * Co-authored-by: Andrew Brown <andrew.brown@shopify.com> * Co-authored-by: Aaron Brady <aaron.brady@shopify.com> | ||||
| * | Feature: delete consumergroups (#2040) | Swen Wenzel | 2020-09-17 | 1 | -0/+41 |
| | | | | | | * Add consumergroup related errors * Add DeleteGroups to protocol.admin * Implement delete_groups feature on KafkaAdminClient | ||||
| * | Add logic for inferring newer broker versions (#2038) | Tincu Gabriel | 2020-05-05 | 1 | -0/+20 |
| | | | | | | | | | | | | | | | * Add logic for inferring newer broker versions - New Fetch / ListOffsets request / response objects - Add new test cases to inferr code based on mentioned objects - Add unit test to check inferred version against whatever resides in KAFKA_VERSION - Add new kafka broker versions to integration list - Add more kafka broker versions to travis task list - Add support for broker version 2.5 id * Implement PR change requests: fewer versions for travis testing, remove unused older versions for inference code, remove one minor version from known server list Do not use newly created ACL request / responses in allowed version lists, due to flexible versions enabling in kafka actually requiring a serialization protocol header update Revert admin client file change | ||||
| * | Admin protocol updates (#1948) | Tyler Lubeck | 2019-12-29 | 1 | -20/+239 |
| | | |||||
| * | Fix response error checking in KafkaAdminClient send_to_controller | Dana Powers | 2019-01-03 | 1 | -3/+3 |
| | | | | | | | | | | | | | Previously we weren't accounting for when the response tuple also has a `error_message` value. Note that in Java, the error fieldname is inconsistent: - `CreateTopicsResponse` / `CreatePartitionsResponse` uses `topic_errors` - `DeleteTopicsResponse` uses `topic_error_codes` So this updates the `CreateTopicsResponse` classes to match. The fix is a little brittle, but should suffice for now. | ||||
| * | Add protocols for {Describe,Create,Delete} Acls | Ulrik Johansson | 2018-11-19 | 1 | -0/+185 |
| | | |||||
| * | 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 response schema | Alex Eftimie | 2018-02-20 | 1 | -1/+2 |
| | | |||||
| * | Add Admin CreatePartitions API call | Alex Eftimie | 2018-02-20 | 1 | -1/+30 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 1 | -2/+2 |
| | | |||||
| * | Add Request/Response structs for kafka broker 1.0.0 | Dana Powers | 2018-02-06 | 1 | -2/+39 |
| | | |||||
| * | Protocol updates for 0.11.0.0 (#1127) | Dana Powers | 2017-07-09 | 1 | -10/+118 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 1 | -15/+15 |
| | | |||||
| * | CreateTopicsRequest / Response v1 (#1012) | Dana Powers | 2017-03-04 | 1 | -3/+34 |
| | | |||||
| * | Add CreateTopics / DeleteTopics Structs (#944) | Jeff Widman | 2017-01-18 | 1 | -2/+60 |
| | | |||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -0/+21 |
| | | |||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | | |||||
| * | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10 | Dana Powers | 2016-05-02 | 1 | -0/+22 |
| | | | | | check_version | ||||
| * | Use version-indexed lists for request/response protocol structsprotocol_versions | Dana Powers | 2016-04-05 | 1 | -6/+18 |
| | | |||||
| * | administration api schemas | Zack Dever | 2015-12-04 | 1 | -0/+44 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |