summaryrefslogtreecommitdiff
path: root/kafka/producer/buffer.py
Commit message (Expand)AuthorAgeFilesLines
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-221-1/+8
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...Dana Powers2016-05-221-2/+4
* 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