| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | 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 |
| | | |||||
| * | Add ssl support to BrokerConnection | Dana Powers | 2016-04-09 | 1 | -3/+91 |
| | | |||||
| * | Add state_change_callback to BrokerConnection | Dana Powers | 2016-04-08 | 1 | -0/+8 |
| | | |||||
| * | Move check_version() logic to BrokerConnection | Dana Powers | 2016-04-08 | 1 | -0/+96 |
| | | |||||
| * | Add BrokerConnection.disconnected() method; update tests | Dana Powers | 2016-04-08 | 1 | -0/+4 |
| | | |||||
| * | Drop timeout param from BrokerConnection.recv() | Dana Powers | 2016-04-08 | 1 | -8/+1 |
| | | |||||
| * | Track last_failure in BrokerConnection.close() | Dana Powers | 2016-04-07 | 1 | -2/+1 |
| | | |||||
| * | Simplify connect logic further | Dana Powers | 2016-04-07 | 1 | -15/+14 |
| | | |||||
| * | Use version-indexed lists for request/response protocol structsprotocol_versions | Dana Powers | 2016-04-05 | 1 | -1/+1 |
| | | |||||
| * | Update imports from kafka.common -> kafka.errors / kafka.structs | Dana Powers | 2016-04-05 | 1 | -2/+2 |
| | | |||||
| * | Handle partial socket send()sock_send_bytes | Dana Powers | 2016-04-05 | 1 | -4/+6 |
| | | |||||
| * | Improve Broker connection handling of not-ready nodes | Dana Powers | 2016-04-04 | 1 | -24/+26 |
| | | | | | | | | - simplify connect state logic - add connecting() method to check state - add BrokerConnection details to exceptions - return NodeNotReady as Future if still connecting | ||||
| * | Changed transltae to replace to support python 3 | Tim Evens | 2016-03-30 | 1 | -1/+2 |
| | | |||||
| * | Kafka IPv6 Support. | Tim Evens | 2016-03-30 | 1 | -6/+42 |
| | | | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234). | ||||
| * | Handle windows socket error codes in BrokerConnection | Dana Powers | 2016-03-17 | 1 | -4/+6 |
| | | |||||
| * | Fix typo ifr.future.fail => ifr.future.failure | Morten Lied Johansen | 2016-02-26 | 1 | -1/+1 |
| | | |||||
| * | Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional | Dana Powers | 2016-02-17 | 1 | -6/+8 |
| | | |||||
| * | Catch dns lookup errors when attempting to connect to nodes | Dana Powers | 2016-01-27 | 1 | -2/+8 |
| | | |||||
| * | Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exception | Dana Powers | 2016-01-23 | 1 | -2/+5 |
| | | |||||
| * | Pylint ignores to fix weird 2.7 error in new pylint version | Dana Powers | 2016-01-23 | 1 | -0/+3 |
| | | |||||
| * | Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warnings | Dana Powers | 2016-01-12 | 1 | -0/+3 |
| | | | | | and KafkaConnection | ||||
| * | Docstring updates | Dana Powers | 2016-01-07 | 1 | -1/+10 |
| | | |||||
| * | Catch py3 ConnectionErrors | Dana Powers | 2016-01-03 | 1 | -7/+18 |
| | | |||||
| * | Check for 0.8.2 GroupCoordinator quirk in BrokerConnection | Dana Powers | 2016-01-03 | 1 | -1/+13 |
| | | |||||
| * | Fix timeout bug in BrokerConnection.connect() | Dana Powers | 2016-01-03 | 1 | -8/+9 |
| | | |||||
| * | Fixup b6a2ad9: Fail with ConnectionErrors in BrokerConnection.send | Dana Powers | 2016-01-02 | 1 | -2/+3 |
| | | |||||
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 1 | -8/+3 |
| | | |||||
| * | BrokerConnection: wrap socket errors in retriable ConnectionError | Dana Powers | 2015-12-30 | 1 | -3/+3 |
| | | |||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 1 | -25/+31 |
| | | |||||
| * | Use _next_correlation_id() method to avoid int overflows | Dana Powers | 2015-12-29 | 1 | -4/+8 |
| | | |||||
| * | Use ConnectionError rather than new DisconnectError | Dana Powers | 2015-12-29 | 1 | -2/+2 |
| | | |||||
| * | Update BrokerConnection for use with async client | Dana Powers | 2015-12-28 | 1 | -39/+74 |
| | | | | | | | | | | - use descriptive names for ConnectionStates enum values - Change default send_buffer_bytes config to 131072 - add can_send_more() and max_in_flight_requests_per_connection config - add blacked_out() and reconnect_backoff_ms config - last_attempt and last_failure are now public attributes - raise TooManyInFlightRequests in conn.send() if cant send more | ||||
| * | Switch BrokerConnection to (mostly) non-blocking IO. | Dana Powers | 2015-12-17 | 1 | -81/+218 |
| | | | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion | ||||
| * | Check for no in-flight-requests in BrokerConnection.recv | Dana Powers | 2015-12-10 | 1 | -0/+3 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |