summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Update docs for api_version_auto_timeout_msUpdate-docs-api_version_auto_timeout_msJeff Widman2019-05-232-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
* Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)Dana Powers2019-03-272-6/+9
* Send pending requests before waiting for responses (#1762)Dana Powers2019-03-271-2/+4
* Dont do client wakeup when sending from sender thread (#1761)Dana Powers2019-03-242-6/+10
* Update sasl configuration docstringsDana Powers2019-03-235-24/+24
* Support SASL OAuthBearer Authentication (#1750)Phong Pham2019-03-227-6/+117
* Maintain shadow cluster metadata for bootstrapping (#1753)Dana Powers2019-03-212-35/+21
* Allow configuration of SSL Ciphers (#1755)Dana Powers2019-03-214-1/+28
* Wrap SSL sockets after connecting (#1754)Dana Powers2019-03-211-19/+11
* Fix race condition in protocol.send_bytes (#1752)Filip Stefanak2019-03-211-1/+2
* Bump version for developmentDana Powers2019-03-141-1/+1
* Release 1.4.51.4.5Dana Powers2019-03-141-1/+1
* Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)Jeff Widman2019-03-141-3/+7
* Retry bootstrapping after backoff when necessary (#1736)Dana Powers2019-03-142-84/+89
* Fix default protocol parser versionDana Powers2019-03-131-0/+3
* Minor updates to client_async.pyDana Powers2019-03-131-4/+4
* Recheck connecting nodes sooner when refreshing metadata (#1737)Dana Powers2019-03-131-3/+1
* Don't recheck version if api_versions data is already cached (#1738)Dana Powers2019-03-131-0/+3
* Attempt to join heartbeat thread during close() (#1735)Dana Powers2019-03-131-3/+6
* 1701 use last offset from fetch v4 if available (#1724)Keith So2019-03-133-0/+28
* Catch thrown OSError by python 3.7 when creating a connection (#1694)Daniel Johansson2019-03-121-0/+3
* Ignore lookup_coordinator result in commit_offsets_async (#1712)Faqa2019-03-121-1/+2
* Synchronize puts to KafkaConsumer protocol buffer during async sendsDana Powers2019-03-121-21/+36
* Do network connections and writes in KafkaClient.poll() (#1729)Dana Powers2019-03-084-49/+76
* Do not require client lock for read-only operations (#1730)Dana Powers2019-03-061-50/+50
* Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (#1722)le-linh2019-03-031-0/+2
* Remove unused importJeff Widman2019-01-281-1/+0
* Improve KafkaConsumer join group / only enable Heartbeat Thread during stable...Dana Powers2019-01-151-11/+23
* Remove unused `skip_double_compressed_messages`Jeff Widman2019-01-132-16/+0
* Timeout all unconnected conns (incl SSL) after request_timeout_msDana Powers2019-01-131-6/+8
* Fix `AttributeError` caused by `getattr()`Jeff Widman2019-01-071-1/+2
* Fix SSL connection testing in Python 3.7Ben Weir2019-01-031-0/+7
* Fix response error checking in KafkaAdminClient send_to_controllerDana Powers2019-01-032-5/+15
View Lorry Controller Status