summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Expand)AuthorAgeFilesLines
* Update conn.pyCameron Boulton2019-08-161-0/+3
* Fix minor typo (#1865)Carson Ip2019-07-141-1/+1
* Catch TimeoutError in BrokerConnection send/recv (#1820)Dana Powers2019-05-291-6/+7
* Do not call state_change_callback with lock (#1775)Dana Powers2019-04-021-13/+21
* Additional BrokerConnection locks to synchronize protocol/IFR state (#1768)Dana Powers2019-04-021-61/+85
* Return connection state explicitly after close in connect() (#1778)Dana Powers2019-04-021-1/+3
* Reset reconnect backoff on SSL connection (#1777)Dana Powers2019-04-021-0/+1
* Fix possible AttribueError during conn._close_socket (#1776)Dana Powers2019-04-011-1/+1
* Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)Dana Powers2019-03-271-3/+0
* Update sasl configuration docstringsDana Powers2019-03-231-4/+4
* Support SASL OAuthBearer Authentication (#1750)Phong Pham2019-03-221-3/+57
* Allow configuration of SSL Ciphers (#1755)Dana Powers2019-03-211-1/+10
* Wrap SSL sockets after connecting (#1754)Dana Powers2019-03-211-19/+11
* Fix race condition in protocol.send_bytes (#1752)Filip Stefanak2019-03-211-1/+2
* Fix default protocol parser versionDana Powers2019-03-131-0/+3
* Don't recheck version if api_versions data is already cached (#1738)Dana Powers2019-03-131-0/+3
* Catch thrown OSError by python 3.7 when creating a connection (#1694)Daniel Johansson2019-03-121-0/+3
* Synchronize puts to KafkaConsumer protocol buffer during async sendsDana Powers2019-03-121-21/+36
* Do network connections and writes in KafkaClient.poll() (#1729)Dana Powers2019-03-081-19/+30
* Timeout all unconnected conns (incl SSL) after request_timeout_msDana Powers2019-01-131-6/+8
* Fix SSL connection testing in Python 3.7Ben Weir2019-01-031-0/+7
* Stop using broker-errors for client-side problemsJeff Widman2018-11-181-1/+1
* Add KafkaAdmin classRichard Lee2018-10-241-0/+10
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-311-2/+6
* add support for smaller topic metadata fetch during bootstrap (#1541)Ning Xie2018-08-311-3/+3
* Improve connection handling when bootstrap list is invalid (#1507)Dana Powers2018-05-261-6/+3
* Stop shadowing `ConnectionError`Jeff Widman2018-05-231-14/+14
* Improve BrokerConnection initialization (#1475)RĂ´mulo Rosa Furtado2018-04-151-1/+1
* Fix KafkaConsumer docstring for request_timeout_ms default (#1459)Dana Powers2018-03-231-2/+2
* Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)Dana Powers2018-03-091-13/+10
* Re-enable logging during broker version check (#1430)Dana Powers2018-03-091-12/+1
* Connection logging cleanups (#1432)Dana Powers2018-03-091-4/+5
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-091-17/+47
* Short-circuit BrokerConnection.close() if already disconnected (#1424)Dana Powers2018-03-091-3/+6
* Only increase reconnect backoff if all addrinfos have been tried (#1423)Dana Powers2018-03-091-1/+4
* Close leaked selector in version check (#1425)Dana Powers2018-03-091-0/+1
* Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ...Dana Powers2018-03-091-15/+25
* Fix BrokerConnection.connection_delay() to return milliseconds (#1414)Dana Powers2018-03-081-2/+9
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-3/+3
* Add Request/Response structs for kafka broker 1.0.0Dana Powers2018-02-061-0/+1
* Fix for Python 3 byte string handling in SASL auth (#1353)Christophe Lecointe2018-01-241-2/+2
* Honor reconnect_backoff in conn.connect() (#1342)Dana Powers2018-01-111-1/+1
* Read all available socket bytes (#1332)Dana Powers2018-01-101-22/+22
* Improve KafkaConsumer cleanup (#1339)Dana Powers2018-01-101-3/+9
* Fix typo in _try_authenticate_plain (#1333)everpcpc2017-12-281-1/+1
* Add security layer negotiation to the GSSAPI authentication. (#1283)Andre Araujo2017-12-261-22/+43
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-1/+1
* Minor Exception cleanupJeff Widman2017-12-121-1/+1
* Refactor dns lookup in BrokerConnection (#1312)Dana Powers2017-12-081-61/+49
* use python standard max value (#1303)lukeWx2017-12-071-1/+1