summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
Commit message (Expand)AuthorAgeFilesLines
* Fix initialization order in KafkaClient (#2119)Pedro Calleja2020-09-161-3/+6
* remove unused importsJames Lamb2020-07-101-1/+0
* Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)Swen Wenzel2019-12-291-9/+6
* Improve docs for reconnect_backoff_max_ms (#1976)Dana Powers2019-12-281-5/+6
* Fix typosCarson Ip2019-11-081-1/+1
* Update docstring to match conn.py's (#1921)David Bouchare2019-10-031-1/+2
* Improve/refactor bootstrap_connectedDana Powers2019-09-301-0/+10
* Change coordinator lock acquisition order (#1821)Dana Powers2019-09-291-1/+3
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-291-2/+27
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-281-3/+7
* Delay converting to secondsJeff Widman2019-05-301-2/+2
* Reduce client poll timeout when no ifrsDana Powers2019-05-291-0/+3
* Do not call state_change_callback with lock (#1775)Dana Powers2019-04-021-8/+8
* Dont treat popped conn.close() as failure in state change callback (#1773)Dana Powers2019-04-011-3/+10
* Avoid race condition on client._conns in send() (#1772)Dana Powers2019-03-311-2/+3
* lock client.check_version (#1771)Dana Powers2019-03-311-0/+5
* Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)Dana Powers2019-03-301-4/+4
* Send pending requests before waiting for responses (#1762)Dana Powers2019-03-271-2/+4
* Dont do client wakeup when sending from sender thread (#1761)Dana Powers2019-03-241-4/+7
* Update sasl configuration docstringsDana Powers2019-03-231-5/+5
* Support SASL OAuthBearer Authentication (#1750)Phong Pham2019-03-221-1/+4
* Maintain shadow cluster metadata for bootstrapping (#1753)Dana Powers2019-03-211-25/+10
* Allow configuration of SSL Ciphers (#1755)Dana Powers2019-03-211-0/+6
* Retry bootstrapping after backoff when necessary (#1736)Dana Powers2019-03-141-83/+66
* Minor updates to client_async.pyDana Powers2019-03-131-4/+4
* Recheck connecting nodes sooner when refreshing metadata (#1737)Dana Powers2019-03-131-3/+1
* Do network connections and writes in KafkaClient.poll() (#1729)Dana Powers2019-03-081-16/+43
* Do not require client lock for read-only operations (#1730)Dana Powers2019-03-061-50/+50
* Break KafkaClient poll if closedDana Powers2018-11-201-0/+2
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
* Use TypeError for invalid typeJeff Widman2018-11-171-1/+1
* set socket timeout for the wake_w (#1577)flaneur2018-11-101-0/+5
* (Attempt to) Fix deadlock between consumer and heartbeat (#1628)Dana Powers2018-11-101-3/+1
* Add KafkaAdmin classRichard Lee2018-10-241-0/+16
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-311-0/+3
* add support for smaller topic metadata fetch during bootstrap (#1541)Ning Xie2018-08-311-3/+10
* Document connections_max_idle_msJeff Widman2018-06-261-0/+5
* Stop shadowing `ConnectionError`Jeff Widman2018-05-231-1/+1
* Minor doc capitalization cleanupJeff Widman2018-04-241-15/+15
* Fix KafkaConsumer docstring for request_timeout_ms default (#1459)Dana Powers2018-03-231-2/+2
* Do not validate api_version against known versions (#1434)Dana Powers2018-03-101-16/+1
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-091-5/+1
* Check timeout type in KafkaClient constructorAndre Araujo2018-02-211-0/+2
* Fix pending completion IndexError bug caused by multiple threads (#1372)Dana Powers2018-02-081-2/+8
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-12/+12
* Remove assertion with side effect (#1348)Buğra Gedik2018-01-231-2/+2
* Read all available socket bytes (#1332)Dana Powers2018-01-101-0/+2
* Improve KafkaConsumer cleanup (#1339)Dana Powers2018-01-101-8/+17
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-283/+182
* use python standard max value (#1303)lukeWx2017-12-071-1/+1
View Lorry Controller Status