summaryrefslogtreecommitdiff
path: root/kafka/producer/buffer.py
Commit message (Collapse)AuthorAgeFilesLines
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵Dana Powers2016-05-221-2/+4
| | | | messagesets
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-1/+1
|
* Always truncate deallocated produce message bufferstruncate_bufferDana Powers2016-03-131-12/+5
|
* Fix bug in SimpleBufferPool memory condition waiting / timeoutDana Powers2016-02-181-4/+5
|
* Support batch_size = 0 in producer buffersbatch_size_zeroDana Powers2016-02-171-4/+6
|
* Add support for LZ4 compressed messages using python-lz4 moduleDana Powers2016-01-251-2/+3
|
* Add MessageSetBuffer and SimpleBufferPool to manage producer messagesDana Powers2016-01-241-0/+388