summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* 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
* 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-291-1/+33
* 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-292-30/+266
* Style updates to scram sasl supportDana Powers2019-12-292-78/+87
* Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)Swen Wenzel2019-12-295-35/+157
* Improve docs for reconnect_backoff_max_ms (#1976)Dana Powers2019-12-285-25/+30
* Fix simple typo: managementment -> managementTim Gates2019-12-081-1/+1
* Fix typosCarson Ip2019-11-087-9/+9
* Remove deprecated `ConnectionError` (#1816)Jeff Widman2019-10-111-4/+0
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-1123-3408/+79
* Fix describe config for multi-broker clusters (#1869)Jeppe Andersen2019-10-111-14/+56
* Update docstring to match conn.py's (#1921)David Bouchare2019-10-031-1/+2
* Release 1.4.7 (#1916)1.4.7Dana Powers2019-09-301-1/+1
* Follow up to PR 1782 -- fix tests (#1914)Dana Powers2019-09-301-1/+2
* Improve/refactor bootstrap_connectedDana Powers2019-09-304-14/+22
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-302-7/+20
* Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due t...Commander Dishwasher2019-09-302-8/+26
* Change coordinator lock acquisition order (#1821)Dana Powers2019-09-292-43/+39
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-293-12/+105
* Do not use wakeup when sending fetch requests from consumer (#1911)Dana Powers2019-09-291-1/+1
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-283-9/+13
* Wrap consumer.poll() for KafkaConsumer iteration (#1902)Dana Powers2019-09-283-11/+74
* Fix Admin Client api version checking; only test ACL integration on 0.11+Dana Powers2019-09-281-4/+10
* Add ACL api to KafkaAdminClient (#1833)Ulrik Johansson2019-09-284-9/+488
* Improve connection lock handling; always use context manager (#1895)Dana Powers2019-09-031-126/+151
* Reduce internal client poll timeout for consumer iterator interface (#1824)Dana Powers2019-08-161-3/+1
View Lorry Controller Status