summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
* 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
|
* When hostname lookup is necessary, do every connect (#812)Evan Bender2016-11-201-5/+9
| | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect.
* Always check for request timeouts (#887)Dana Powers2016-11-181-4/+4
| | | | * Check for requests that timeout without causing a socket read/write event
* typo (#883)sharego2016-11-151-1/+1
| | | type error
* Update param in warning (#878)Dana Powers2016-11-141-2/+2
|\ | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners
| * Update param in warningJeff Widman2016-11-111-2/+2
| | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners
* | Fix typosJeff Widman2016-11-141-2/+2
|/
* Monkeypatch max_in_flight_requests_per_connection when checking broker ↵Dana Powers2016-09-281-6/+11
| | | | version (#834)
* HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on ↵Dana Powers2016-08-081-11/+15
| | | | reconnects) (#799)
* Send combined size and payload bytes to socket to avoid potentially split ↵Dana Powers2016-08-041-6/+6
| | | | packets with TCP_NODELAY (#797)
* Instrument metrics in BrokerConnectionDana Powers2016-08-041-0/+123
|
* Remove unused import from kafka.connDana Powers2016-08-041-1/+1
|
* Add BrokerConnection docstring with configuration parametersDana Powers2016-08-041-0/+65
|
* minor tweaks to get authentication workingLars Jørgen Solberg2016-08-031-8/+7
|
* Use callbacks for sasl handshake request / responseDana Powers2016-08-031-59/+62
|
* implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-031-3/+103
|
* Always absolute_importabsolute_importDana Powers2016-08-021-0/+2
|
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
|
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)Dana Powers2016-08-011-6/+14
|
* Delete KafkaConnection class (#769)Dana Powers2016-07-171-187/+0
|
* #761 Follow-up: use api_version tuples in BrokerConnection.check_versionDana Powers2016-07-161-11/+10
|
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-2/+7
|
* Add ssl_password to default_config dicts. Send ssl_password when loading ↵Ashley McKemie2016-07-081-1/+3
| | | | cert chains (#750)
* assert will be disabled by "python -O" (#736)tyronecai2016-06-231-4/+4
|
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-191-5/+5
| | | | | * Mute all connection logging during conn.check_version * Always process pending MetadataRequest in conn.check_version * KakfaClient.check_version: Scan all brokers until a version is identified or timeout
* Catch response decode errors and log details (#715)Dana Powers2016-06-011-1/+14
|
* Add CRL support to SSL support (#683)Vincent Bernat2016-05-191-0/+11
| | | | A user can provide a CRL whose peer certificate will be checked against. This only works with Python 3.4+ and Python 2.7.9+.
* Fixup BrokerConnection check_version strict error checking: 0.9 will fail ↵Dana Powers2016-05-171-0/+7
| | | | with CorrelationIdError
View Lorry Controller Status