summaryrefslogtreecommitdiff
path: root/kafka/producer/kafka.py
Commit message (Expand)AuthorAgeFilesLines
* 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
* Replace %s with %r in producer debug log message (#973)Alex2017-03-031-1/+1
* Fix BrokerConnection api_version docs default (#909)Jeff Widman2017-02-281-4/+4
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-091-4/+4
* Add kafka.serializer interfaces (#912)Dana Powers2016-12-191-12/+13
* Sort partitions before calling partitioner (#905)ms7s2016-12-191-1/+1
* Fixup doc references to max_in_flight_requests_per_connectionDana Powers2016-12-171-1/+1
* DOC: Fix typo 'Defualt' -> 'Default'. (#895)Rolando (Max) Espinoza2016-11-301-1/+1
* Added ssl_password config option to KafkaProducer class, identical to… (#830)kierkegaard132016-09-151-0/+3
* Improve KafkaProducer docstring re retries configDana Powers2016-08-201-3/+5
* Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metricsDana Powers2016-08-041-1/+1
* Fix misspelling of "password" (#793)Samuel Taylor2016-08-041-1/+1
* implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-031-1/+12
* Clarify api_version=str deprecation warningDana Powers2016-08-021-1/+1
* Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)Dana Powers2016-08-011-2/+2
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)Dana Powers2016-08-011-0/+5
* Add KafkaClient metricsmore_metricsDana Powers2016-07-171-1/+2
* KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770...Dana Powers2016-07-171-4/+6
* Expose selector type as config option (#764)Dana Powers2016-07-161-1/+5