summaryrefslogtreecommitdiff
path: root/kafka/producer/future.py
Commit message (Collapse)AuthorAgeFilesLines
* Add `log_start_offset` to message protocol parsing (#2020)Tincu Gabriel2020-03-251-3/+3
| | | This is in preparation for adding `zstd` support.
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
| | | | Fix #1633
* Support produce with Kafka record headersHeikki Nousiainen2018-09-271-5/+5
|
* use absolute imports everywhere (#1362)Kevin Tindall2018-02-061-2/+2
|
* Fix timestamp not passed to RecordMetadata (#1273)Taras Voinarovskyi2017-10-221-1/+3
| | | | | | | | * Fix timestamp not being passed to RecordMetadata properly * Add more tests for LegacyBatch * Fix producer test for recordmetadata
* KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵Dana Powers2016-07-171-10/+19
| | | | (#770 / #594)
* Simplify RecordMetadata; short circuit callbacks (#768)Dana Powers2016-07-171-19/+7
| | | | Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks
* Dont use soon-to-be-reserved keyword await as function name ↵Dana Powers2016-05-221-2/+2
| | | | (FutureProduceResult) (#697)
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵Dana Powers2016-05-221-6/+12
| | | | messagesets
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+1
|
* Fix for FutureProduceResult.await on python2.6Dana Powers2016-03-131-1/+2
|
* Add thread-aware futures for use with KafkaProducerDana Powers2016-01-241-0/+66