summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Add a bunch of TODOsremove-some-unused-codeJeff Widman2019-10-113-0/+3
* Remove deprecated `ConnectionError` (#1816)Jeff Widman2019-10-111-4/+0
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-1123-3408/+79
* Fix describe config for multi-broker clusters (#1869)Jeppe Andersen2019-10-111-14/+56
* Update docstring to match conn.py's (#1921)David Bouchare2019-10-031-1/+2
* Release 1.4.7 (#1916)1.4.7Dana Powers2019-09-301-1/+1
* Follow up to PR 1782 -- fix tests (#1914)Dana Powers2019-09-301-1/+2
* Improve/refactor bootstrap_connectedDana Powers2019-09-304-14/+22
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-302-7/+20
* Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due t...Commander Dishwasher2019-09-302-8/+26
* Change coordinator lock acquisition order (#1821)Dana Powers2019-09-292-43/+39
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-293-12/+105
* Do not use wakeup when sending fetch requests from consumer (#1911)Dana Powers2019-09-291-1/+1
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-283-9/+13
* Wrap consumer.poll() for KafkaConsumer iteration (#1902)Dana Powers2019-09-283-11/+74
* Fix Admin Client api version checking; only test ACL integration on 0.11+Dana Powers2019-09-281-4/+10
* Add ACL api to KafkaAdminClient (#1833)Ulrik Johansson2019-09-284-9/+488
* Improve connection lock handling; always use context manager (#1895)Dana Powers2019-09-031-126/+151
* Reduce internal client poll timeout for consumer iterator interface (#1824)Dana Powers2019-08-161-3/+1
* Update conn.pyCameron Boulton2019-08-161-0/+3
* Break FindCoordinator into request/response methodsJeff Widman2019-07-311-32/+48
* Fix minor typo (#1865)Carson Ip2019-07-142-2/+2
* Update link to upstream Kafka docsJeff Widman2019-07-111-1/+1
* Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient`Jeff Widman2019-06-281-0/+3
* Update KafkaAdminClient DocsRob Cardy2019-06-211-1/+2
* Allow the coordinator to auto-commit for all api_version.Jay Chan2019-06-201-1/+1
* Break consumer operations into request / response methods (#1845)Jeff Widman2019-06-191-94/+155
* Use dedicated connection for group coordinator (#1822)Dana Powers2019-06-192-25/+17
* Delay converting to secondsJeff Widman2019-05-301-2/+2
* Reduce client poll timeout when no ifrsDana Powers2019-05-291-0/+3
* Catch TimeoutError in BrokerConnection send/recv (#1820)Dana Powers2019-05-291-6/+7
* Remove unused/weird comment line (#1813)Jeff Widman2019-05-281-1/+0
* Update docs for api_version_auto_timeout_ms (#1812)Jeff Widman2019-05-242-2/+2
* Fix typo in _fetch_all_topic_metadata function (#1809)Brian Sang2019-05-231-1/+1
* Make partitions_for_topic a read-through cache (#1781)Brian Sang2019-05-221-8/+25
* Remove unused imports (#1808)Jeff Widman2019-05-221-2/+2
* Use futures to parallelize calls to _send_request_to_node() (#1807)Lou-Cipher2019-05-211-34/+75
* Update link to kafka docsJeff Widman2019-05-171-1/+1
* A little python cleanup (#1805)Jeff Widman2019-05-171-4/+2
* Bump version for development of next releaseDana Powers2019-04-031-1/+1
* Release 1.4.61.4.6Dana Powers2019-04-021-1/+1
* Do not call state_change_callback with lock (#1775)Dana Powers2019-04-022-21/+29
* Additional BrokerConnection locks to synchronize protocol/IFR state (#1768)Dana Powers2019-04-021-61/+85
* Return connection state explicitly after close in connect() (#1778)Dana Powers2019-04-021-1/+3
* Reset reconnect backoff on SSL connection (#1777)Dana Powers2019-04-021-0/+1
* Fix possible AttribueError during conn._close_socket (#1776)Dana Powers2019-04-011-1/+1
* Dont treat popped conn.close() as failure in state change callback (#1773)Dana Powers2019-04-011-3/+10
* Avoid race condition on client._conns in send() (#1772)Dana Powers2019-03-311-2/+3
* lock client.check_version (#1771)Dana Powers2019-03-311-0/+5
* Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)Dana Powers2019-03-301-4/+4
View Lorry Controller Status