| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Include the node id in BrokerConnection __repr__ (#1009) | Dana Powers | 2017-03-03 | 1 | -2/+2 | |
| | | ||||||
| * | Mark last_attempt time during connection close to fix blackout calculation ↵ | Dana Powers | 2017-03-03 | 1 | -0/+1 | |
| | | | | | (#1008) | |||||
| * | Catch socket errors during ssl handshake (#1007) | Dana Powers | 2017-03-03 | 1 | -1/+1 | |
| | | ||||||
| * | Fix sasl reconnect bug: auth future must be reset on close (#1003) | Dana Powers | 2017-03-03 | 1 | -0/+1 | |
| | | ||||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+3 | |
| | | ||||||
| * | Move BrokerConnection docstring to class (#968) | Jeff Widman | 2017-02-08 | 1 | -68/+69 | |
| | | ||||||
| * | Add support for Python built without ssl (#939) (#954) | Sho Minagawa | 2017-02-03 | 1 | -17/+28 | |
| | | ||||||
| * | Do not re-close a disconnected connection | Dana Powers | 2017-01-19 | 1 | -1/+0 | |
| | | ||||||
| * | Drop unused last_failure time from BrokerConnection | Dana Powers | 2017-01-19 | 1 | -4/+1 | |
| | | ||||||
| * | Use connection state functions where possible | Dana Powers | 2017-01-19 | 1 | -0/+1 | |
| | | ||||||
| * | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-19 | 1 | -19/+27 | |
| | | ||||||
| * | Fix typo: coorelation --> correlation (#929) | Jeff Widman | 2017-01-11 | 1 | -5/+5 | |
| | | ||||||
| * | Make SSL warning list the correct Python versions (#924) | Jeff Widman | 2017-01-04 | 1 | -3/+3 | |
| | | ||||||
| * | Bug fix: ret = err => ret = err.errno (#907) | guojh | 2016-12-17 | 1 | -1/+1 | |
| | | ||||||
| * | Fixup doc references to max_in_flight_requests_per_connection | Dana Powers | 2016-12-17 | 1 | -1/+1 | |
| | | ||||||
| * | Fix typo: passowrd --> password (#901) | Jeff Widman | 2016-12-12 | 1 | -1/+1 | |
| | | ||||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 | |
| | | ||||||
| * | When hostname lookup is necessary, do every connect (#812) | Evan Bender | 2016-11-20 | 1 | -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 Powers | 2016-11-18 | 1 | -4/+4 | |
| | | | | | * Check for requests that timeout without causing a socket read/write event | |||||
| * | typo (#883) | sharego | 2016-11-15 | 1 | -1/+1 | |
| | | | | type error | |||||
| * | Update param in warning (#878) | Dana Powers | 2016-11-14 | 1 | -2/+2 | |
| |\ | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | |||||
| | * | Update param in warning | Jeff Widman | 2016-11-11 | 1 | -2/+2 | |
| | | | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | |||||
| * | | Fix typos | Jeff Widman | 2016-11-14 | 1 | -2/+2 | |
| |/ | ||||||
| * | Monkeypatch max_in_flight_requests_per_connection when checking broker ↵ | Dana Powers | 2016-09-28 | 1 | -6/+11 | |
| | | | | | version (#834) | |||||
| * | HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on ↵ | Dana Powers | 2016-08-08 | 1 | -11/+15 | |
| | | | | | reconnects) (#799) | |||||
| * | Send combined size and payload bytes to socket to avoid potentially split ↵ | Dana Powers | 2016-08-04 | 1 | -6/+6 | |
| | | | | | packets with TCP_NODELAY (#797) | |||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -0/+123 | |
| | | ||||||
| * | Remove unused import from kafka.conn | Dana Powers | 2016-08-04 | 1 | -1/+1 | |
| | | ||||||
| * | Add BrokerConnection docstring with configuration parameters | Dana Powers | 2016-08-04 | 1 | -0/+65 | |
| | | ||||||
| * | minor tweaks to get authentication working | Lars Jørgen Solberg | 2016-08-03 | 1 | -8/+7 | |
| | | ||||||
| * | Use callbacks for sasl handshake request / response | Dana Powers | 2016-08-03 | 1 | -59/+62 | |
| | | ||||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -3/+103 | |
| | | ||||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 | |
| | | ||||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -1/+1 | |
| | | ||||||
| * | Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) | Dana Powers | 2016-08-01 | 1 | -6/+14 | |
| | | ||||||
| * | Delete KafkaConnection class (#769) | Dana Powers | 2016-07-17 | 1 | -187/+0 | |
| | | ||||||
| * | #761 Follow-up: use api_version tuples in BrokerConnection.check_version | Dana Powers | 2016-07-16 | 1 | -11/+10 | |
| | | ||||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 1 | -2/+7 | |
| | | ||||||
| * | Add ssl_password to default_config dicts. Send ssl_password when loading ↵ | Ashley McKemie | 2016-07-08 | 1 | -1/+3 | |
| | | | | | cert chains (#750) | |||||
| * | assert will be disabled by "python -O" (#736) | tyronecai | 2016-06-23 | 1 | -4/+4 | |
| | | ||||||
| * | check_version should scan nodes until version found or timeout (#731) | Dana Powers | 2016-06-19 | 1 | -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 Powers | 2016-06-01 | 1 | -1/+14 | |
| | | ||||||
| * | Add CRL support to SSL support (#683) | Vincent Bernat | 2016-05-19 | 1 | -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 Powers | 2016-05-17 | 1 | -0/+7 | |
| | | | | | with CorrelationIdError | |||||
| * | supplement socket.gaierror exception in BrokerConnection.connect() (#687) | Erik Beebe | 2016-05-17 | 1 | -3/+10 | |
| | | | | supplement socket.gaierror exception to include the host/port | |||||
| * | kafka/conn: use original hostname for SSL checks (#682) | Vincent Bernat | 2016-05-17 | 1 | -2/+4 | |
| | | | | | | | | | When the address family is not provided, `self.host` is resolved to one of the IP addresses and replaced by it. The SSL context is then built using `self.host` which is now an IP instead of the proper name. Most of the time, hostname cannot be checked this way. Therefore, save the original hostname in a dedicated property and use this property for the SSL context. | |||||
| * | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10 | Dana Powers | 2016-05-02 | 1 | -1/+2 | |
| | | | | | check_version | |||||
| * | Improve socket disconnect handlingdisconnects | Dana Powers | 2016-04-25 | 1 | -4/+22 | |
| | | ||||||
| * | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 1 | -24/+99 | |
| | | | | | Fixes #641 | |||||
| * | Wait for future.is_done in check_version (fix for windows) | Dana Powers | 2016-04-24 | 1 | -5/+5 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |