summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Allow disabling thread wakeup in send_request_to_node (#2335)HEADmasterAndrew Zhang2023-03-021-2/+3
* Fix producerconfigs documentation link (#2226)MandarJKulkarni2021-08-031-1/+1
* Fix typo: veriication -> verification (#2207)Dongwook Chan2021-02-211-1/+1
* fix typo in documentation (#2178)Nikolay Vasiliev2021-02-201-2/+2
* Core Protocol: Add support for flexible versions (#2151)Tincu Gabriel2020-12-025-16/+294
* Support configuration of custom kafka client for Admin/Consumer/Producer (#2144)Tincu Gabriel2020-12-023-8/+17
* Hotfix: TypeError: object of type 'dict_itemiterator' has no len() (#2167)Krzysztof Grabowski2020-11-191-2/+3
* Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162)Lourens Naudé2020-11-154-2/+57
* KafkaConsumer: Exit poll if consumer is closed (#2152)Rauli Ikonen2020-11-151-2/+4
* Only try to update sensors fetch lag if the unpacked list contains elements (...Keith So2020-11-051-2/+3
* Cover sticky assignor's metadata method with tests (#2161)Valeria Chernenko2020-11-051-3/+7
* Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154)Valeria Chernenko2020-10-301-1/+1
* Bump version for developmentDana Powers2020-09-301-1/+1
* Patch Release 2.0.22.0.2Dana Powers2020-09-291-1/+1
* KIP-54: Implement sticky partition assignment strategy (#2057)Valeria Chernenko2020-09-295-1/+897
* Fix crc32c deprecation warning (#2128)Jeff Widman2020-09-171-1/+1
* Merge _find_coordinator_id methods (#2127)Jeff Widman2020-09-171-42/+27
* Lint cleanup (#2126)Jeff Widman2020-09-171-4/+3
* Feature: delete consumergroups (#2040)Swen Wenzel2020-09-173-4/+142
* Fix initialization order in KafkaClient (#2119)Pedro Calleja2020-09-161-3/+6
* Allow configurable timeouts in admin client check versionHimanshu Mishra2020-09-161-2/+2
* Enhancement for Kafka Admin Client's "Describe Consumer Group" (#2035)Apurva0072020-09-162-14/+46
* producer/kafka: Disable logging during object destruction (#2043)Gioele2020-09-071-0/+8
* Add kafka.structs docstrings (#2080)Mostafa-Elmenbawy2020-09-071-3/+58
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-075-8/+48
* Fix typo (#2096)KimDongMin2020-09-071-1/+1
* Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064)huangcuiyang2020-09-071-8/+12
* remove unused importsJames Lamb2020-07-103-3/+0
* Add logic for inferring newer broker versions (#2038)Tincu Gabriel2020-05-054-5/+298
* Add `log_start_offset` to message protocol parsing (#2020)Tincu Gabriel2020-03-254-15/+107
* Fix docs by adding SASL mentionJeff Widman2020-03-021-1/+2
* 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-191-1/+1
* KAFKA-8962: Use least_loaded_node() for describe_topics()Jeff Widman2020-02-161-15/+7
* 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-101-1/+1
* _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
* 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-062-1/+37
* Remove unused importJeff Widman2020-02-051-1/+0
* Remove some dead codeJeff Widman2020-02-053-196/+0
* Fix slots usage and use more slotsCarson Ip2020-02-054-0/+26
* 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-294-9/+16
* 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
View Lorry Controller Status