summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Expand)AuthorAgeFilesLines
* Stop shadowing `ConnectionError`Stop-shadowing-native-python-ConnectionError-exceptionJeff Widman2018-05-101-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
* changed for to use enumerate() (#1301)Benn Roth2017-12-061-2/+1
* Use socket timeout of request_timeout_ms to prevent blocking forever on send ...Dana Powers2017-10-251-6/+7
* Fix more gssapi errors (#1280)Dana Powers2017-10-241-1/+4
* Fixup for PR 1258 / _try_authenticateDana Powers2017-10-211-1/+4
* Merge pull request #1258 from dpkp/pending_completionsTaras Voinarovskyi2017-10-211-14/+25
|\
| * Move callback processing from BrokerConnection to KafkaClientpending_completionsDana Powers2017-10-151-14/+25
* | Cleanup gssapi code; fix bug report re AttributeError. (#1262)Dana Powers2017-10-161-10/+9
|/
* Fix SASL authentication bugs (#1257)Dana Powers2017-10-151-23/+34
* Check for disconnects during ssl handshake and sasl authentication (#1249)Dana Powers2017-10-101-31/+42
* Always wait for completion during SASL/GSSAPI authentication (#1248)Dana Powers2017-10-101-26/+15
* Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)Dana Powers2017-10-101-145/+44
* Fix typoJeff Widman2017-10-061-1/+1
* Small fixes to SASL documentation and logging; validate security_protocol (#1...Dana Powers2017-10-031-21/+26
* Remove raw traceback (#1221)dbgasaway2017-10-011-3/+5
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+0
* BrokerConnection receive bytes pipe (#1032)Dana Powers2017-08-151-77/+84
* Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...Taras Voinarovskiy2017-08-071-1/+1
* Added basic support for offsets_for_times API. Still needs to group by nodes ...Taras Voinarovskiy2017-08-071-0/+1
* Add private map of api key -> min/max versions to BrokerConnection (#1169)Dana Powers2017-08-061-11/+21
* conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162)Hannu Valtonen2017-08-011-1/+3
* added gssapi support (Kerberos) for SASL (#1152)Harald2017-07-201-2/+75
* Use logging's built-in string interpolationJeff Widman2017-07-071-4/+4
* KIP-144: Exponential backoff for broker reconnections (#1124)Dana Powers2017-06-191-3/+37
* Warn dont raise on DNS lookup failures (#1091)Dana Powers2017-05-031-5/+7
* Timeout idle connections via connections_max_idle_ms (#1068)Dana Powers2017-04-101-2/+4
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-141-4/+4