| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Catch socket.errors when sending / recving bytes on wake socketpairwake_socketpair_exceptions | Dana Powers | 2017-04-04 | 1 | -2/+4 |
| | | |||||
| * | Fix poll() hyperlink in KafkaClient | Jeff Widman | 2017-03-29 | 1 | -1/+1 |
| | | | | Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit. | ||||
| * | Fix typo (#1054) | Jeff Widman | 2017-03-27 | 1 | -1/+1 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 1 | -6/+1 |
| | | |||||
| * | Add optional kwarg to ready and is_ready to disable metadata-priority logic ↵ | Dana Powers | 2017-03-08 | 1 | -7/+16 |
| | | | | | (#1017) | ||||
| * | Add ClusterMetadata documentation | Dana Powers | 2017-03-07 | 1 | -0/+4 |
| | | |||||
| * | Fixup comment reference to _maybe_connect | Dana Powers | 2017-03-07 | 1 | -1/+1 |
| | | |||||
| * | Add client info logging re bootstrap; log connection attempts to balance ↵ | Dana Powers | 2017-03-06 | 1 | -0/+3 |
| | | | | | with close | ||||
| * | Added `max_bytes` option and FetchRequest_v3 usage. (#962) | Taras Voinarovskyi | 2017-03-06 | 1 | -0/+2 |
| | | | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse | ||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+4 |
| | | |||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 1 | -11/+11 |
| | | |||||
| * | Move docstring so it shows up in Sphinx/RTD (#952) | Jeff Widman | 2017-01-21 | 1 | -83/+83 |
| | | |||||
| * | Use connection state functions where possible | Dana Powers | 2017-01-19 | 1 | -3/+3 |
| | | |||||
| * | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-19 | 1 | -1/+1 |
| | | |||||
| * | Fix possible request draining in ensure_active_group (#896) | Dana Powers | 2016-12-02 | 1 | -9/+10 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 |
| | | |||||
| * | setting proper topic value in case if it's empty (#867) | Alexander Sibiryakov | 2016-11-18 | 1 | -11/+4 |
| | | |||||
| * | Always check for request timeouts (#887) | Dana Powers | 2016-11-18 | 1 | -0/+8 |
| | | | | | * Check for requests that timeout without causing a socket read/write event | ||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 1 | -2/+2 |
| | | |||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 1 | -0/+2 |
| | | | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments | ||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -0/+2 |
| | | |||||
| * | Add connection-count to KafkaClient metrics | Dana Powers | 2016-08-04 | 1 | -3/+12 |
| | | |||||
| * | Add connection-creation-rate / connection-close-rate to KafkaClientMetrics | Dana Powers | 2016-08-04 | 1 | -0/+13 |
| | | |||||
| * | Fix misspelling of "password" (#793) | Samuel Taylor | 2016-08-04 | 1 | -1/+1 |
| | | |||||
| * | Ignore socket.error when checking for protocol out of sync prior to socket ↵ | Dana Powers | 2016-08-03 | 1 | -4/+7 |
| | | | | | close (#792) | ||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -0/+10 |
| | | |||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Move kafka.socketpair to kafka.vendor.socketpair | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Move kafka.selectors34 to kafka.vendor.selectors34 | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) | Dana Powers | 2016-08-01 | 1 | -7/+11 |
| | | |||||
| * | Add KafkaClient metricsmore_metrics | Dana Powers | 2016-07-17 | 1 | -1/+51 |
| | | |||||
| * | Explicit format string argument indices for python 2.6 compatibility | Dana Powers | 2016-07-17 | 1 | -1/+1 |
| | | |||||
| * | Expose selector type as config option (#764) | Dana Powers | 2016-07-16 | 1 | -1/+5 |
| | | |||||
| * | Protect writes to wakeup socket with threading lock (#763 / #709) | Dana Powers | 2016-07-16 | 1 | -2/+6 |
| | | |||||
| * | Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1 | Dana Powers | 2016-07-16 | 1 | -3/+14 |
| | | |||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 1 | -2/+28 |
| | | |||||
| * | Add ssl_password to default_config dicts. Send ssl_password when loading ↵ | Ashley McKemie | 2016-07-08 | 1 | -0/+1 |
| | | | | | cert chains (#750) | ||||
| * | Wakeup socket optimizations (#740) | Dana Powers | 2016-06-26 | 1 | -1/+1 |
| | | |||||
| * | Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) | Dana Powers | 2016-06-20 | 1 | -30/+43 |
| | | |||||
| * | check_version should scan nodes until version found or timeout (#731) | Dana Powers | 2016-06-19 | 1 | -12/+41 |
| | | | | | | * 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 | ||||
| * | Update KafkaClient.least_loaded_node (#730) | Dana Powers | 2016-06-18 | 1 | -23/+17 |
| | | | | | | | - Main node loop should check all known brokers, not just conn objects, which is consistent with the official java client. - This fixes a bug which could cause least_loaded_node to always return the same unavailable node | ||||
| * | Close selector when closing the client connection to fix fd leak. (#729) | Michael Smith | 2016-06-17 | 1 | -0/+1 |
| | | |||||
| * | Fix socket leaks in KafkaClient (#696) | Dana Powers | 2016-05-22 | 1 | -10/+10 |
| | | | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close() | ||||
| * | Add CRL support to SSL support (#683) | Vincent Bernat | 2016-05-19 | 1 | -0/+6 |
| | | | | | 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+. | ||||
| * | Improve socket disconnect handlingdisconnects | Dana Powers | 2016-04-25 | 1 | -1/+1 |
| | | |||||
| * | Disable standard metadata refresh hook during bootstrap | Dana Powers | 2016-04-25 | 1 | -0/+2 |
| | | |||||
| * | handle unexpected reads in client_async | James Brown | 2016-04-25 | 1 | -0/+19 |
| | | | | | Should fix #661. | ||||
| * | as per code review | Chris Lane | 2016-04-14 | 1 | -2/+2 |
| | | |||||
| * | to squelch the __del issue | Chris Lane | 2016-04-13 | 1 | -2/+4 |
| | | |||||
| * | Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducer | Dana Powers | 2016-04-09 | 1 | -0/+21 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |