summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Expand)AuthorAgeFilesLines
* HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reco...Dana Powers2016-08-081-11/+15
* Send combined size and payload bytes to socket to avoid potentially split pac...Dana Powers2016-08-041-6/+6
* 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 cert...Ashley McKemie2016-07-081-1/+3
* 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
* 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
* Fixup BrokerConnection check_version strict error checking: 0.9 will fail wit...Dana Powers2016-05-171-0/+7
* supplement socket.gaierror exception in BrokerConnection.connect() (#687)Erik Beebe2016-05-171-3/+10
* kafka/conn: use original hostname for SSL checks (#682)Vincent Bernat2016-05-171-2/+4
* Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_ve...check_version_0_10Dana Powers2016-05-021-1/+2
* Improve socket disconnect handlingdisconnectsDana Powers2016-04-251-4/+22
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-241-24/+99
* Wait for future.is_done in check_version (fix for windows)Dana Powers2016-04-241-5/+5
* Add ssl support to BrokerConnectionDana Powers2016-04-091-3/+91
* Add state_change_callback to BrokerConnectionDana Powers2016-04-081-0/+8
* Move check_version() logic to BrokerConnectionDana Powers2016-04-081-0/+96
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-081-0/+4
* Drop timeout param from BrokerConnection.recv()Dana Powers2016-04-081-8/+1
* Track last_failure in BrokerConnection.close()Dana Powers2016-04-071-2/+1
* Simplify connect logic furtherDana Powers2016-04-071-15/+14
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-1/+1
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
* Handle partial socket send()sock_send_bytesDana Powers2016-04-051-4/+6
* Improve Broker connection handling of not-ready nodesDana Powers2016-04-041-24/+26
* Changed transltae to replace to support python 3Tim Evens2016-03-301-1/+2
* Kafka IPv6 Support.Tim Evens2016-03-301-6/+42
* Handle windows socket error codes in BrokerConnectionDana Powers2016-03-171-4/+6
* Fix typo ifr.future.fail => ifr.future.failureMorten Lied Johansen2016-02-261-1/+1
* Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optionalDana Powers2016-02-171-6/+8
* Catch dns lookup errors when attempting to connect to nodesDana Powers2016-01-271-2/+8
* Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exceptionDana Powers2016-01-231-2/+5
* Pylint ignores to fix weird 2.7 error in new pylint versionDana Powers2016-01-231-0/+3
* Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ...deprecation_warningsDana Powers2016-01-121-0/+3
* Docstring updatesDana Powers2016-01-071-1/+10
* Catch py3 ConnectionErrorsDana Powers2016-01-031-7/+18
* Check for 0.8.2 GroupCoordinator quirk in BrokerConnectionDana Powers2016-01-031-1/+13
* Fix timeout bug in BrokerConnection.connect()Dana Powers2016-01-031-8/+9
View Lorry Controller Status