| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | rename to `"zstd"`add-lz4-and-snappy-to-extras_require | Jeff Widman | 2020-09-16 | 1 | -1/+1 |
| | | |||||
| * | add python-zstandard | Jeff Widman | 2020-09-16 | 1 | -0/+1 |
| | | |||||
| * | Add lz4 and snappy to extras_require | Jeff Widman | 2020-09-16 | 1 | -1/+5 |
| | | | | As noted in https://kafka-python.readthedocs.io/en/master/install.html these are some additional optional libs that we should be specifying in `extras_require` so that callers can specify them if desired. | ||||
| * | Added crc32c extra requirement as per issue #2068 | Misha Seltzer | 2020-09-16 | 1 | -0/+1 |
| | | |||||
| * | Enhancement for Kafka Admin Client's "Describe Consumer Group" (#2035) | Apurva007 | 2020-09-16 | 3 | -16/+146 |
| | | | | | | | Adding namedtuples for DescribeConsumerGroup response; Adding Serialization of MemberData and MemberAssignment for the response Co-authored-by: Apurva Telang <atelang@paypal.com> Co-authored-by: Jeff Widman <jeff@jeffwidman.com> | ||||
| * | producer/kafka: Disable logging during object destruction (#2043) | Gioele | 2020-09-07 | 1 | -0/+8 |
| | | |||||
| * | Update example.py (#2081) | Mostafa-Elmenbawy | 2020-09-07 | 1 | -18/+28 |
| | | | | Co-authored-by: MostafaElmenabawy <momenabawy@synapse-analytics.io> | ||||
| * | Add kafka.structs docstrings (#2080) | Mostafa-Elmenbawy | 2020-09-07 | 1 | -3/+58 |
| | | | | Co-authored-by: MostafaElmenabawy <momenabawy@synapse-analytics.io> | ||||
| * | Add support for `zstd` compression (#2021) | Tincu Gabriel | 2020-09-07 | 10 | -23/+75 |
| | | |||||
| * | fixed the broken compatibility page link (#2045) | Anurag Rana | 2020-09-07 | 1 | -1/+1 |
| | | |||||
| * | Fix typo (#2096) | KimDongMin | 2020-09-07 | 1 | -1/+1 |
| | | |||||
| * | Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064) | huangcuiyang | 2020-09-07 | 1 | -8/+12 |
| | | |||||
| * | Python 3.8 support (#2088) | Swen Kooij | 2020-07-22 | 5 | -9/+11 |
| | | |||||
| * | remove unused imports | James Lamb | 2020-07-10 | 4 | -4/+0 |
| | | |||||
| * | Rename README to README.md (#2055) | qhzxc0015 | 2020-05-26 | 1 | -0/+0 |
| | | | | rename | ||||
| * | Add logic for inferring newer broker versions (#2038) | Tincu Gabriel | 2020-05-05 | 11 | -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 Gabriel | 2020-03-25 | 4 | -15/+107 |
| | | | | This is in preparation for adding `zstd` support. | ||||
| * | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |