summaryrefslogtreecommitdiff
path: root/kafka/client_async.py
Commit message (Expand)AuthorAgeFilesLines
* Add ssl_password to default_config dicts. Send ssl_password when loading cert...Ashley McKemie2016-07-081-0/+1
* 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
* Update KafkaClient.least_loaded_node (#730)Dana Powers2016-06-181-23/+17
* 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
* Add CRL support to SSL support (#683)Vincent Bernat2016-05-191-0/+6
* 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
* 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 cal...Dana Powers2016-04-081-19/+19
* 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
* Improve KafkaClient connect and ready handlingnode_not_readyDana Powers2016-04-041-26/+19
* Kafka IPv6 Support.Tim Evens2016-03-301-4/+6
* Use socketpair for KafkaClient wake pipe windows compatibilityDana Powers2016-03-171-6/+8
* Check for None returned from least_loaded_node when no brokers are availablenone_least_loaded_nodeDana Powers2016-03-131-0/+4
* Merge pull request #557 from dpkp/socket_buffer_size_optionalDana Powers2016-02-181-4/+6
|\
| * Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optionalDana Powers2016-02-171-4/+6
* | break up some circular references and close client wake pipe on __del__aisch2016-02-161-0/+4
|/
* bootstrap node should be last resort in least_loaded_node()Dana Powers2016-02-151-0/+7
* KafkaClient.connection_delay should return 0 when connecting to avoid unneces...Dana Powers2016-02-151-4/+10
* Fixup RequestTimeoutError -> RequestTimedOutErrorDana Powers2016-02-151-1/+1
* Improve KafkaClient.check_version()Dana Powers2016-02-151-13/+27
* Implement KafkaConsumer.topics()Dana Powers2016-02-011-1/+5
* Add error 104 / Connection reset by peer to expected check_version errorsDana Powers2016-01-251-2/+2
* Small KafkaClient.check_version() improvementsDana Powers2016-01-251-3/+20
* Log new KafkaClient under kafka.client until files are mergedDana Powers2016-01-251-1/+1
* Write bytes to wake_fdDana Powers2016-01-241-1/+1
* KafkaClient.add_topic() -- for use by async producerDana Powers2016-01-231-0/+15
* Optionally sleep in KafkaClient.poll(), add KafkaClient.wakeup()Dana Powers2016-01-231-7/+37
* Add back connection_delay method to KafkaClient - used by KafkaProducerDana Powers2016-01-181-0/+20
* Remove sleep call in client.poll -- expect callers to manage this and log war...Dana Powers2016-01-121-6/+5
* Receive all available responses in client._pollDana Powers2016-01-101-3/+4
* If a completed future is polled, do not blockDana Powers2016-01-101-6/+13
View Lorry Controller Status