Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Add API version determination code for newer kafka brokersadd_new_api_versions | Taras Voinarovskyi | 2020-03-19 | 1 | -0/+5 |
| | |||||
* | Add 2.1.1 to build_integration (#2019) | Tincu Gabriel | 2020-03-16 | 1 | -1/+1 |
| | |||||
* | Fix docs by adding SASL mention | Jeff Widman | 2020-03-02 | 1 | -1/+2 |
| | | | | | This was previously supported but wasn't documented. Fix #1990. | ||||
* | Set length of header value to 0 if None | kvfi | 2020-03-02 | 1 | -1/+3 |
| | |||||
* | Bump version for development | Dana Powers | 2020-02-19 | 1 | -1/+1 |
| | |||||
* | Patch Release 2.0.12.0.1 | Dana Powers | 2020-02-19 | 3 | -1/+16 |
| | |||||
* | KAFKA-8962: Use least_loaded_node() for describe_topics() | Jeff Widman | 2020-02-16 | 1 | -15/+7 |
| | | | | | | | | | | | | | | | | | | | | | | | In KAFKA-8962 the `AdminClient.describe_topics()` call was changed from using the controller to using the `least_loaded_node()`: https://github.com/apache/kafka/commit/317089663cc7ff4fdfcba6ee434f455e8ae13acd#diff-6869b8fccf6b098cbcb0676e8ceb26a7R1540 As a result, no metadata request/response processing needs to happen through the controller, so it's safe to remove the custom error-checking. Besides, I don't think this error-checking even added any value because AFAIK no metadata response would return a `NotControllerError` because the recipient broker wouldn't realize the metadata request was intended for only the controller. Originally our admin client was implemented using the least-loaded-node, then later updated to the controller. So updating it back to least-loaded node is a simple case of reverting the associated commits. This reverts commit 7195f0369c7dbe25aea2c3fed78d2b4f772d775b. This reverts commit 6e2978edee9a06e9dbe60afcac226b27b83cbc74. This reverts commit f92889af79db08ef26d89cb18bd48c7dd5080010. | ||||
* | Fix topic error parsing in MetadataResponse | Jeff Tribble | 2020-02-15 | 1 | -6/+11 |
| | |||||
* | Bump version for development of next release | Dana Powers | 2020-02-10 | 1 | -1/+1 |
| | |||||
* | Release 2.0.02.0.0 | Dana Powers | 2020-02-10 | 3 | -1/+100 |
| | |||||
* | _send_request_to_controller returns a raw result, not a future | Tyler Lubeck | 2020-02-06 | 1 | -6/+6 |
| | |||||
* | Use the controller for topic metadata requests | Tyler Lubeck | 2020-02-06 | 1 | -6/+9 |
| | | | | Closes #1994 | ||||
* | Implement list_topics, describe_topics, and describe_cluster | Tyler Lubeck | 2020-02-06 | 1 | -6/+40 |
| | |||||
* | Implement methods to convert a Struct object to a pythonic object (#1951) | Tyler Lubeck | 2020-02-06 | 3 | -1/+273 |
| | | | Implement methods to convert a Struct object to a pythonic object | ||||
* | Remove unused import | Jeff Widman | 2020-02-05 | 1 | -1/+0 |
| | | | | | Forgot to remove this in https://github.com/dpkp/kafka-python/pull/1925 / ca2d76304bfe3900f995e6f0e4377b2ef654997e | ||||
* | Remove some dead code | Jeff Widman | 2020-02-05 | 3 | -196/+0 |
| | |||||
* | Use print() function in both Python 2 and Python 3 | Christian Clauss | 2020-02-05 | 1 | -3/+4 |
| | |||||
* | Use ==/!= to compare str, bytes, and int literals | Christian Clauss | 2020-02-05 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | Identity is not the same thing as equality in Python so use ==/!= to compare str, bytes, and int literals. In Python >= 3.8, these instances will raise __SyntaxWarnings__ so it is best to fix them now. https://docs.python.org/3.8/whatsnew/3.8.html#porting-to-python-3-8 % __python__ ``` >>> consumer = "cons" >>> consumer += "umer" >>> consumer == "consumer" True >>> consumer is "consumer" False >>> 0 == 0.0 True >>> 0 is 0.0 False ``` | ||||
* | Fix benchmarks to use pyperf | Carson Ip | 2020-02-05 | 4 | -13/+13 |
| | |||||
* | Fix slots usage and use more slots | Carson Ip | 2020-02-05 | 4 | -0/+26 |
| | | | | | Use empty slots for ABC classes, otherwise classes which inherit from them will still have __dict__. Also use __slots__ for more classes. | ||||
* | Update 2.4.0 resource files for sasl integration | Dana Powers | 2019-12-29 | 2 | -0/+6 |
| | |||||
* | kafka 2.4.0 (#1972) | Vanessa Vuibert | 2019-12-29 | 7 | -7/+198 |
| | |||||
* | Do not log topic-specific errors in full metadata fetch (#1980) | Dana Powers | 2019-12-29 | 1 | -0/+4 |
| | |||||
* | Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979) | Dana Powers | 2019-12-29 | 6 | -13/+20 |
| | |||||
* | Do not block on sender thread join after timeout in producer.close() (#1974) | Dana Powers | 2019-12-29 | 1 | -5/+1 |
| | |||||
* | Raise AssertionError if consumer closed in poll() (#1978) | Dana Powers | 2019-12-29 | 1 | -0/+3 |
| | |||||
* | Reset conn configs on exception in conn.check_version() (#1977) | Dana Powers | 2019-12-29 | 1 | -2/+7 |
| | |||||
* | Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not ↵ | Dana Powers | 2019-12-29 | 1 | -2/+5 |
| | | | | error (#1975) | ||||
* | Implement __eq__ and __hash__ for ACL objects (#1955) | Tyler Lubeck | 2019-12-29 | 2 | -1/+125 |
| | |||||
* | Fixes KafkaAdminClient returning `IncompatibleBrokerVersion` when passing an ↵ | Ian Bucad | 2019-12-29 | 1 | -0/+1 |
| | | | | `api_version` (#1953) | ||||
* | Fix typo | Dana Powers | 2019-12-29 | 1 | -1/+1 |
| | |||||
* | Admin protocol updates (#1948) | Tyler Lubeck | 2019-12-29 | 3 | -30/+284 |
| | |||||
* | Style updates to scram sasl support | Dana Powers | 2019-12-29 | 3 | -82/+93 |
| | |||||
* | Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918) | Swen Wenzel | 2019-12-29 | 57 | -136/+619 |
| | |||||
* | Add crc32c to README and docs | Dana Powers | 2019-12-29 | 2 | -0/+16 |
| | |||||
* | Improve docs for reconnect_backoff_max_ms (#1976) | Dana Powers | 2019-12-28 | 5 | -25/+30 |
| | |||||
* | xfail test_describe_configs_topic_resource_returns_configs (Issue #1929) | Dana Powers | 2019-12-28 | 1 | -0/+3 |
| | |||||
* | Fix simple typo: managementment -> management | Tim Gates | 2019-12-08 | 1 | -1/+1 |
| | | | | Closes #1965 | ||||
* | Fix typos | Carson Ip | 2019-11-08 | 9 | -11/+11 |
| | |||||
* | Fix doc import paths (#1933) | Jeff Widman | 2019-10-21 | 2 | -2/+2 |
| | | | Since `SimpleClient` was deleted, the new `KafkaClient` currently resides at `kafka.client_async.KafkaClient`... that may get updated in the future, so instead just import the `KafkaClient` from the top-level. | ||||
* | Remove unused/empty .gitsubmodules file (#1928) | Jeff Widman | 2019-10-11 | 1 | -0/+0 |
| | | | | | This is a legacy file that has not been used in a long time. It's leftover from when the tests used git submodules to pull down kafka source... today they use shell scripts to pull down the binaries. | ||||
* | Remove deprecated `ConnectionError` (#1816) | Jeff Widman | 2019-10-11 | 1 | -4/+0 |
| | | | | | | This has been deprecated for a bit in favor of `KafkaConnectionError` because it conflicts with Python's built-in `ConnectionError`. Time to remove it as part of cleaning up our old deprecated code. | ||||
* | Remove SimpleClient, Producer, Consumer, Unittest (#1196) | Jeff Widman | 2019-10-11 | 53 | -7392/+98 |
| | | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`. | ||||
* | Fix describe config for multi-broker clusters (#1869) | Jeppe Andersen | 2019-10-11 | 2 | -15/+112 |
| | | | | | | | * Fix describe config for multi-broker clusters Currently all describe config requests are sent to "least loaded node". Requests for broker configs must, however, be sent to the specific broker, otherwise an error is returned. Only topic requests can be handled by any node. This changes the logic to send all describe config requests to the specific broker. | ||||
* | convert test_admin_integration to pytest (#1923) | Ulrik Johansson | 2019-10-07 | 3 | -103/+90 |
| | |||||
* | Update docstring to match conn.py's (#1921) | David Bouchare | 2019-10-03 | 1 | -1/+2 |
| | |||||
* | Release 1.4.7 (#1916)1.4.7 | Dana Powers | 2019-09-30 | 3 | -7/+121 |
| | |||||
* | Add KAFKA 2.3.0 to test matrix (#1915) | Dana Powers | 2019-09-30 | 21 | -9/+975 |
| | |||||
* | Follow up to PR 1782 -- fix tests (#1914) | Dana Powers | 2019-09-30 | 2 | -4/+4 |
| | |||||
* | Improve/refactor bootstrap_connected | Dana Powers | 2019-09-30 | 4 | -14/+22 |
| |