summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Try to fix pylint issuebump_versionsTaras Voinarovskyi2020-05-261-1/+1
|
* Rename README to README.md (#2055)qhzxc00152020-05-261-0/+0
| | | rename
* Add logic for inferring newer broker versions (#2038)Tincu Gabriel2020-05-0511-10/+315
| | | | | | | | | | | | | | * 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
* Add `log_start_offset` to message protocol parsing (#2020)Tincu Gabriel2020-03-254-15/+107
| | | This is in preparation for adding `zstd` support.
* Add 2.1.1 to build_integration (#2019)Tincu Gabriel2020-03-161-1/+1
|
* Fix docs by adding SASL mentionJeff Widman2020-03-021-1/+2
| | | | | This was previously supported but wasn't documented. Fix #1990.
* Set length of header value to 0 if Nonekvfi2020-03-021-1/+3
|
* Bump version for developmentDana Powers2020-02-191-1/+1
|
* Patch Release 2.0.12.0.1Dana Powers2020-02-193-1/+16
|
* KAFKA-8962: Use least_loaded_node() for describe_topics()Jeff Widman2020-02-161-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 MetadataResponseJeff Tribble2020-02-151-6/+11
|
* Bump version for development of next releaseDana Powers2020-02-101-1/+1
|
* Release 2.0.02.0.0Dana Powers2020-02-103-1/+100
|
* _send_request_to_controller returns a raw result, not a futureTyler Lubeck2020-02-061-6/+6
|
* Use the controller for topic metadata requestsTyler Lubeck2020-02-061-6/+9
| | | | Closes #1994
* Implement list_topics, describe_topics, and describe_clusterTyler Lubeck2020-02-061-6/+40
|
* Implement methods to convert a Struct object to a pythonic object (#1951)Tyler Lubeck2020-02-063-1/+273
| | | Implement methods to convert a Struct object to a pythonic object
* Remove unused importJeff Widman2020-02-051-1/+0
| | | | | Forgot to remove this in https://github.com/dpkp/kafka-python/pull/1925 / ca2d76304bfe3900f995e6f0e4377b2ef654997e
* Remove some dead codeJeff Widman2020-02-053-196/+0
|
* Use print() function in both Python 2 and Python 3Christian Clauss2020-02-051-3/+4
|
* Use ==/!= to compare str, bytes, and int literalsChristian Clauss2020-02-051-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 pyperfCarson Ip2020-02-054-13/+13
|
* Fix slots usage and use more slotsCarson Ip2020-02-054-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 integrationDana Powers2019-12-292-0/+6
|
* kafka 2.4.0 (#1972)Vanessa Vuibert2019-12-297-7/+198
|
* Do not log topic-specific errors in full metadata fetch (#1980)Dana Powers2019-12-291-0/+4
|
* Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)Dana Powers2019-12-296-13/+20
|
* Do not block on sender thread join after timeout in producer.close() (#1974)Dana Powers2019-12-291-5/+1
|
* Raise AssertionError if consumer closed in poll() (#1978)Dana Powers2019-12-291-0/+3
|
* Reset conn configs on exception in conn.check_version() (#1977)Dana Powers2019-12-291-2/+7
|
* Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not ↵Dana Powers2019-12-291-2/+5
| | | | error (#1975)
* Implement __eq__ and __hash__ for ACL objects (#1955)Tyler Lubeck2019-12-292-1/+125
|
* Fixes KafkaAdminClient returning `IncompatibleBrokerVersion` when passing an ↵Ian Bucad2019-12-291-0/+1
| | | | `api_version` (#1953)
* Fix typoDana Powers2019-12-291-1/+1
|
* Admin protocol updates (#1948)Tyler Lubeck2019-12-293-30/+284
|
* Style updates to scram sasl supportDana Powers2019-12-293-82/+93
|
* Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)Swen Wenzel2019-12-2957-136/+619
|
* Add crc32c to README and docsDana Powers2019-12-292-0/+16
|
* Improve docs for reconnect_backoff_max_ms (#1976)Dana Powers2019-12-285-25/+30
|
* xfail test_describe_configs_topic_resource_returns_configs (Issue #1929)Dana Powers2019-12-281-0/+3
|
* Fix simple typo: managementment -> managementTim Gates2019-12-081-1/+1
| | | | Closes #1965
* Fix typosCarson Ip2019-11-089-11/+11
|
* Fix doc import paths (#1933)Jeff Widman2019-10-212-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 Widman2019-10-111-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 Widman2019-10-111-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 Widman2019-10-1153-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 Andersen2019-10-112-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 Johansson2019-10-073-103/+90
|
* Update docstring to match conn.py's (#1921)David Bouchare2019-10-031-1/+2
|
* Release 1.4.7 (#1916)1.4.7Dana Powers2019-09-303-7/+121
|
View Lorry Controller Status