summaryrefslogtreecommitdiff
path: root/kafka/producer/buffer.py
Commit message (Expand)AuthorAgeFilesLines
* Issue 985: Clear memory wait condition before raising Exception (#999)Dana Powers2017-03-021-0/+1
* Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metricsDana Powers2016-08-041-6/+11
* Avoid buffer overread when compressing messageset in KafkaProducerDana Powers2016-07-171-1/+2
* KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770...Dana Powers2016-07-171-1/+1
* Add initial producer-sender metricsDana Powers2016-07-161-5/+15
* Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compressionDana Powers2016-07-141-16/+23
* 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