summaryrefslogtreecommitdiff
path: root/kafka/producer
Commit message (Expand)AuthorAgeFilesLines
* Remove some dead codeJeff Widman2020-02-051-179/+0
* 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
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-114-589/+1
* Improve/refactor bootstrap_connectedDana Powers2019-09-302-11/+11
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-301-7/+14
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-281-1/+1
* 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
* Dont do client wakeup when sending from sender thread (#1761)Dana Powers2019-03-241-2/+3
* 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
* Remove unused importJeff Widman2019-01-281-1/+0
* #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-186-13/+13
* 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-101-0/+1
* Stop using deprecated log.warn()Jeff Widman2018-10-261-3/+3
* Vendor `six` consistentlyJeff Widman2018-10-221-2/+2
* Update remote urls: snappy, https, etcJeff Widman2018-10-221-2/+2
* Support produce with Kafka record headersHeikki Nousiainen2018-09-273-17/+27
* 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-053-8/+8
* Stop shadowing `ConnectionError`Jeff Widman2018-05-231-1/+0
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-233-17/+25
* 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-068-33/+33
* 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-072-2/+2
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...Taras Voinarovskyi2017-10-252-6/+18
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-222-7/+8
* Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#...Nathanael Smith2017-10-171-0/+3
* Added minor fixes for PR reviewTaras2017-10-122-16/+4
* 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-114-180/+90
* Expand metrics docs (#1243)Jeff Widman2017-10-081-6/+15
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+1
* Drop unused sleep kwarg to poll (#1177)Dana Powers2017-08-151-1/+1
* Fix batch expiry messages to state secondsDominic Evans2017-07-261-3/+3
* 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
View Lorry Controller Status