summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
* 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
| | | | (#1281)
* 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 KafkaClient
| * 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
| | | | | | * Use _send_bytes_blocking in BrokerConnection * _try_authenticate should call recv() so that futures are resolved * _sasl_auth_future can be reset if recv() causes disconnect * validate sasl_mechanism against SaslHandShakeResponse enabled_mechanisms
* 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 ↵Dana Powers2017-10-031-21/+26
| | | | (#1231)
* Remove raw traceback (#1221)dbgasaway2017-10-011-3/+5
|
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+0
| | | | | * Removed a few unused imports * Added note on socketpair monkey-path
* BrokerConnection receive bytes pipe (#1032)Dana Powers2017-08-151-77/+84
|
* Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵Taras Voinarovskiy2017-08-071-1/+1
| | | | review issues
* Added basic support for offsets_for_times API. Still needs to group by nodes ↵Taras Voinarovskiy2017-08-071-0/+1
| | | | and send in parallel.
* 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
|
* Add client info logging re bootstrap; log connection attempts to balance ↵Dana Powers2017-03-061-1/+1
| | | | with close
* Small cleanup for #962Dana Powers2017-03-061-4/+9
|
* Added `max_bytes` option and FetchRequest_v3 usage. (#962)Taras Voinarovskyi2017-03-061-1/+24
| | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse
* Add more debug-level connection loggingDana Powers2017-03-061-0/+7
|
* Do not need str(self) when formatting to %sDana Powers2017-03-061-16/+16
|
* When closing a broker connection without error, fail in-flight-requests with ↵Dana Powers2017-03-031-1/+1
| | | | Cancelled (#1010)
* Include the node id in BrokerConnection __repr__ (#1009)Dana Powers2017-03-031-2/+2
|
* Mark last_attempt time during connection close to fix blackout calculation ↵Dana Powers2017-03-031-0/+1
| | | | (#1008)
* Catch socket errors during ssl handshake (#1007)Dana Powers2017-03-031-1/+1
|
* Fix sasl reconnect bug: auth future must be reset on close (#1003)Dana Powers2017-03-031-0/+1
|
* Fix BrokerConnection api_version docs default (#909)Jeff Widman2017-02-281-4/+3
|
* Move BrokerConnection docstring to class (#968)Jeff Widman2017-02-081-68/+69
|
* Add support for Python built without ssl (#939) (#954)Sho Minagawa2017-02-031-17/+28
|
* Do not re-close a disconnected connectionDana Powers2017-01-191-1/+0
|
* Drop unused last_failure time from BrokerConnectionDana Powers2017-01-191-4/+1
|
* Use connection state functions where possibleDana Powers2017-01-191-0/+1
|
* Pass error to BrokerConnection.close()Dana Powers2017-01-191-19/+27
|
* Fix typo: coorelation --> correlation (#929)Jeff Widman2017-01-111-5/+5
|
* Make SSL warning list the correct Python versions (#924)Jeff Widman2017-01-041-3/+3
|
* Bug fix: ret = err => ret = err.errno (#907)guojh2016-12-171-1/+1
|
* Fixup doc references to max_in_flight_requests_per_connectionDana Powers2016-12-171-1/+1
|
* Fix typo: passowrd --> password (#901)Jeff Widman2016-12-121-1/+1
|
* DOC: Fix typo 'Defualt' -> 'Default'. (#895)Rolando (Max) Espinoza2016-11-301-1/+1
|
View Lorry Controller Status