summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Maintain shadow bootstrap cluster metadatabootstrap_clusterDana Powers2019-03-212-34/+20
* 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
* #1681 add copy() in metrics() to avoid thread safety issues (#1682)Tosi Émeric2018-12-272-4/+4
* Bugfix: Types need identity comparisonJeff Widman2018-12-131-1/+1
* Bump version for developmentDana Powers2018-11-201-1/+1
* Release 1.4.41.4.4Dana Powers2018-11-201-1/+1
* Rename KafkaAdmin to KafkaAdminClientJeff Widman2018-11-203-20/+20
* Break KafkaClient poll if closedDana Powers2018-11-201-0/+2
* Add protocols for {Describe,Create,Delete} AclsUlrik Johansson2018-11-191-0/+185
* Bugfix: Always set this_groups_coordinator_idJeff Widman2018-11-191-1/+3
* Various docstring / pep8 / code hygiene cleanupsJeff Widman2018-11-181-71/+86
* Fix describe_groupsJeff Widman2018-11-181-13/+50
* Set a clear default value for `validate_only`/`include_synonyms`Jeff Widman2018-11-181-8/+8
* Fix list_consumer_groups() to query all brokersJeff Widman2018-11-181-5/+39
* Add list_consumer_group_offsets()Jeff Widman2018-11-182-1/+77
* Fix send to controllerJeff Widman2018-11-181-44/+89
* Add group coordinator lookupJeff Widman2018-11-181-0/+40
* Remove support for api versions as strings from KafkaAdminJeff Widman2018-11-181-10/+0
* Be explicit with tuples for %s formattingJeff Widman2018-11-1822-38/+38
* Stop using broker-errors for client-side problemsJeff Widman2018-11-183-38/+44
* Use TypeError for invalid typeJeff Widman2018-11-171-1/+1
* raising logging level on messages signalling data loss (#1553)Alexander Sibiryakov2018-11-101-2/+3
* set socket timeout for the wake_w (#1577)flaneur2018-11-102-0/+6
* (Attempt to) Fix deadlock between consumer and heartbeat (#1628)Dana Powers2018-11-102-4/+2
* Fix typoJeff Widman2018-11-071-1/+1
* Pre-compile pack/unpack function callsbillyevans2018-10-291-13/+29
* Document KafkaAdmin classJeff Widman2018-10-291-0/+7
View Lorry Controller Status