summaryrefslogtreecommitdiff
path: root/kafka/producer/future.py
Commit message (Collapse)AuthorAgeFilesLines
* 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