summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
Commit message (Collapse)AuthorAgeFilesLines
* Fix possible request draining in ensure_active_group (#896)Dana Powers2016-12-021-9/+10
|
* DOC: Fix typo 'Defualt' -> 'Default'. (#895)Rolando (Max) Espinoza2016-11-301-1/+1
|
* setting proper topic value in case if it's empty (#867)Alexander Sibiryakov2016-11-181-11/+4
|
* Always check for request timeouts (#887)Dana Powers2016-11-181-0/+8
| | | | * Check for requests that timeout without causing a socket read/write event
* Fix typosJeff Widman2016-11-141-2/+2
|
* Added ssl_password config option to KafkaProducer class, identical to… (#830)kierkegaard132016-09-151-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 BrokerConnectionDana Powers2016-08-041-0/+2
|
* Add connection-count to KafkaClient metricsDana Powers2016-08-041-3/+12
|
* Add connection-creation-rate / connection-close-rate to KafkaClientMetricsDana Powers2016-08-041-0/+13
|
* Fix misspelling of "password" (#793)Samuel Taylor2016-08-041-1/+1
|
* Ignore socket.error when checking for protocol out of sync prior to socket ↵Dana Powers2016-08-031-4/+7
| | | | close (#792)
* implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-031-0/+10
|
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
|
* Move kafka.socketpair to kafka.vendor.socketpairDana Powers2016-08-011-1/+1
|
* Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-011-1/+1
|
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)Dana Powers2016-08-011-7/+11
|
* Add KafkaClient metricsmore_metricsDana Powers2016-07-171-1/+51
|
* Explicit format string argument indices for python 2.6 compatibilityDana Powers2016-07-171-1/+1
|
* Expose selector type as config option (#764)Dana Powers2016-07-161-1/+5
|
* Protect writes to wakeup socket with threading lock (#763 / #709)Dana Powers2016-07-161-2/+6
|
* Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1Dana Powers2016-07-161-3/+14
|
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-161-2/+28
|
* Add ssl_password to default_config dicts. Send ssl_password when loading ↵Ashley McKemie2016-07-081-0/+1
| | | | cert chains (#750)
* Wakeup socket optimizations (#740)Dana Powers2016-06-261-1/+1
|
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-201-30/+43
|
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-191-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 Powers2016-06-181-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 Smith2016-06-171-0/+1
|
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-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 Bernat2016-05-191-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 handlingdisconnectsDana Powers2016-04-251-1/+1
|
* Disable standard metadata refresh hook during bootstrapDana Powers2016-04-251-0/+2
|
* handle unexpected reads in client_asyncJames Brown2016-04-251-0/+19
| | | | Should fix #661.
* as per code reviewChris Lane2016-04-141-2/+2
|
* to squelch the __del issueChris Lane2016-04-131-2/+4
|
* Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducerDana Powers2016-04-091-0/+21
|
* Check for pending ssl bytes in KafkaClient loopDana Powers2016-04-091-0/+12
|
* Handle SSL HANDSHAKE state in KafkaClient state change handlerDana Powers2016-04-091-2/+4
|
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-32/+33
|
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-1/+4
|
* Drop bootstrap connection once first normal broker is connectedDana Powers2016-04-081-0/+6
|
* Add private _refresh_on_disconnects flag to KafkaClientDana Powers2016-04-081-2/+8
|
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵Dana Powers2016-04-081-19/+19
| | | | callback
* Move check_version() logic to BrokerConnectionDana Powers2016-04-081-78/+3
|
* Default sleep=True in client.pollDana Powers2016-04-081-1/+1
|
* Make _wake_r socket non-blocking; drop select from _clear_wake_fdDana Powers2016-04-081-3/+4
|
* More _maybe_connect refactoring -- preparing for selectorsDana Powers2016-04-081-7/+15
|
* Use conn.connecting() checks to support multiple connecting statesDana Powers2016-04-071-3/+3
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-9/+9
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+1
|
View Lorry Controller Status