summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Merge _find_coordinator_id methodsmerge-_find_coordinator_ids-methodsJeff Widman2020-09-171-42/+27
* Lint cleanup (#2126)Jeff Widman2020-09-171-4/+3
* Feature: delete consumergroups (#2040)Swen Wenzel2020-09-174-5/+219
* 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
* Added crc32c extra requirement as per issue #2068Misha Seltzer2020-09-161-0/+1
* Enhancement for Kafka Admin Client's "Describe Consumer Group" (#2035)Apurva0072020-09-163-16/+146
* producer/kafka: Disable logging during object destruction (#2043)Gioele2020-09-071-0/+8
* Update example.py (#2081)Mostafa-Elmenbawy2020-09-071-18/+28
* Add kafka.structs docstrings (#2080)Mostafa-Elmenbawy2020-09-071-3/+58
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-0710-23/+75
* fixed the broken compatibility page link (#2045)Anurag Rana2020-09-071-1/+1
* Fix typo (#2096)KimDongMin2020-09-071-1/+1
* Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064)huangcuiyang2020-09-071-8/+12
* Python 3.8 support (#2088)Swen Kooij2020-07-225-9/+11
* remove unused importsJames Lamb2020-07-104-4/+0
* Rename README to README.md (#2055)qhzxc00152020-05-261-0/+0
* Add logic for inferring newer broker versions (#2038)Tincu Gabriel2020-05-0511-10/+315
* Add `log_start_offset` to message protocol parsing (#2020)Tincu Gabriel2020-03-254-15/+107
* 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
* 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
* 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
* 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
* Remove unused importJeff Widman2020-02-051-1/+0
* 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
* Fix benchmarks to use pyperfCarson Ip2020-02-054-13/+13
* Fix slots usage and use more slotsCarson Ip2020-02-054-0/+26
* 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
* 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
* Fix typoDana Powers2019-12-291-1/+1
* Admin protocol updates (#1948)Tyler Lubeck2019-12-293-30/+284
View Lorry Controller Status