| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | 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 | |
| | | ||||||
| * | Added a function to determine if bootstrap is successfully connected (#1876) | PandllCom | 2019-09-30 | 2 | -7/+20 | |
| | | ||||||
| * | Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due ↵ | Commander Dishwasher | 2019-09-30 | 3 | -12/+26 | |
| | | | | | to topic deletion while rebalancing (#1782) | |||||
| * | Change coordinator lock acquisition order (#1821) | Dana Powers | 2019-09-29 | 2 | -43/+39 | |
| | | ||||||
| * | Send socket data via non-blocking IO with send buffer (#1912) | Dana Powers | 2019-09-29 | 4 | -13/+108 | |
| | | ||||||
| * | Do not use wakeup when sending fetch requests from consumer (#1911) | Dana Powers | 2019-09-29 | 2 | -2/+2 | |
| | | ||||||
| * | Rely on socket selector to detect completed connection attempts (#1909) | Dana Powers | 2019-09-28 | 5 | -11/+15 | |
| | | ||||||
| * | Wrap consumer.poll() for KafkaConsumer iteration (#1902) | Dana Powers | 2019-09-28 | 3 | -11/+74 | |
| | | ||||||
| * | Skip admin integration tests -- travis fixture issues | Dana Powers | 2019-09-28 | 1 | -4/+7 | |
| | | ||||||
| * | Update kafka.properties for ACL tests (0.11+ only) | Dana Powers | 2019-09-28 | 7 | -18/+3 | |
| | | ||||||
| * | Fix Admin Client api version checking; only test ACL integration on 0.11+ | Dana Powers | 2019-09-28 | 2 | -9/+18 | |
| | | ||||||
| * | Fixup test_admin_integration test fixtures | Dana Powers | 2019-09-28 | 1 | -5/+14 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |