summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Synchronize puts to KafkaConsumer protocol buffer during async sendsconn_lock_async_sendDana Powers2019-03-111-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
* Stop using deprecated log.warn()Jeff Widman2018-10-261-3/+3
* Add temp workaround for upstream pylint bugJeff Widman2018-10-261-1/+3
* Add KafkaAdmin classRichard Lee2018-10-249-0/+637
* Vendor enum34Jeff Widman2018-10-221-0/+841
* Vendor `six` consistentlyJeff Widman2018-10-222-4/+4
* Update remote urls: snappy, https, etcJeff Widman2018-10-223-5/+5
* Bump vendored `six` to `1.11.0`Jeff Widman2018-10-221-16/+42
* Support produce with Kafka record headersHeikki Nousiainen2018-09-273-17/+27
* Expose record headers in ConsumerRecordsHeikki Nousiainen2018-09-271-3/+5
* Expose ConsumerRebalanceListener in allBen Harack2018-09-271-1/+1
* Remove ConsumerTimeoutJonathan Emord2018-09-271-4/+0
* Clear the metrics dictionary on close. (#1569)Kishore Nallan2018-08-311-0/+2
* Return future from commit_offsets_async (#1560)Mike Lang2018-08-311-1/+6
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-314-4/+17
View Lorry Controller Status