summaryrefslogtreecommitdiff
path: root/kafka/producer/kafka.py
Commit message (Expand)AuthorAgeFilesLines
* Fix producerconfigs documentation link (#2226)MandarJKulkarni2021-08-031-1/+1
* Fix typo: veriication -> verification (#2207)Dongwook Chan2021-02-211-1/+1
* Support configuration of custom kafka client for Admin/Consumer/Producer (#2144)Tincu Gabriel2020-12-021-4/+7
* producer/kafka: Disable logging during object destruction (#2043)Gioele2020-09-071-0/+8
* Add support for `zstd` compression (#2021)Tincu Gabriel2020-09-071-2/+6
* Do not block on sender thread join after timeout in producer.close() (#1974)Dana Powers2019-12-291-5/+1
* Enable SCRAM-SHA-256 and SCRAM-SHA-512 for sasl (#1918)Swen Wenzel2019-12-291-5/+5
* Improve docs for reconnect_backoff_max_ms (#1976)Dana Powers2019-12-281-5/+6
* Fix typosCarson Ip2019-11-081-1/+1
* Improve/refactor bootstrap_connectedDana Powers2019-09-301-11/+8
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-301-7/+14
* Remove unused/weird comment line (#1813)Jeff Widman2019-05-281-1/+0
* Update docs for api_version_auto_timeout_ms (#1812)Jeff Widman2019-05-241-1/+1
* Update sasl configuration docstringsDana Powers2019-03-231-5/+5
* Support SASL OAuthBearer Authentication (#1750)Phong Pham2019-03-221-1/+4
* Allow configuration of SSL Ciphers (#1755)Dana Powers2019-03-211-0/+6
* #1681 add copy() in metrics() to avoid thread safety issues (#1682)Tosi Émeric2018-12-271-2/+2
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-5/+5
* set socket timeout for the wake_w (#1577)flaneur2018-11-101-0/+1
* Update remote urls: snappy, https, etcJeff Widman2018-10-221-2/+2
* Support produce with Kafka record headersHeikki Nousiainen2018-09-271-5/+13
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-311-1/+4
* add support for smaller topic metadata fetch during bootstrap (#1541)Ning Xie2018-08-311-0/+1
* Document connections_max_idle_msJeff Widman2018-06-261-0/+5
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-051-4/+4
* Validate that serializers generate bytes-like (or None) data (#1420)Dana Powers2018-03-101-2/+3
* Do not validate api_version against known versions (#1434)Dana Powers2018-03-101-2/+1
* Fix byte size estimation with kafka producer (#1393)Blake Embrey2018-02-241-1/+1
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-14/+14
* fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)C.YAO2018-01-231-1/+1
* Read all available socket bytes (#1332)Dana Powers2018-01-101-0/+2
* Raise non-API exceptions (#1316)Jeff Widman2017-12-211-5/+1
* use python standard max value (#1303)lukeWx2017-12-071-1/+1
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...Taras Voinarovskyi2017-10-251-4/+11
* Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#...Nathanael Smith2017-10-171-0/+3
* Added minor fixes for PR reviewTaras2017-10-121-1/+1
* Remove the check for timestamp None in producer, as it's done in RecordBatch ...Taras2017-10-121-2/+0
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...Taras2017-10-111-9/+34
* Expand metrics docs (#1243)Jeff Widman2017-10-081-6/+15
* Add note, that `max_in_flight_requests_per_connection>1` may change order or ...Taras Voinarovskyi2017-07-171-1/+4
* producer: fix produce timeout message (#1151)Mika Eloranta2017-07-171-1/+1
* producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)Hannu Valtonen2017-06-191-1/+1
* KIP-144: Exponential backoff for broker reconnections (#1124)Dana Powers2017-06-191-0/+9
* Update exception docstringAndrew Kowalik2017-06-161-1/+1
* raise KafkaTimeoutException when flush times outAndrew Kowalik2017-06-161-0/+4
* Follow-up to #1068: remove not-implemented commentsDana Powers2017-04-101-1/+1
* Timeout idle connections via connections_max_idle_ms (#1068)Dana Powers2017-04-101-1/+1
* Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etcDana Powers2017-03-071-12/+14
* change default timeout of KafkaProducer.close() to threading.TIMEOUT_MAXgaosheng2017-03-061-2/+6
* Add sphinx formatting to hyperlink methods (#898)Jeff Widman2017-03-031-8/+8