delta/python-packages/kafka-python.git/kafka/producer/buffer.py, branch fix_close_socket_attribute_error github.com: mumrah/kafka-python.git use absolute imports everywhere (#1362) 2018-02-06T20:10:45+00:00 Kevin Tindall kevinkjt2000@users.noreply.github.com 2018-02-06T20:10:45+00:00 9ae0e590b5ea93a9c07d71b55b593e0fcc973bc6 






Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format
2017-10-11T15:09:17+00:00

Taras
voyn1991@gmail.com

2017-10-09T21:13:16+00:00

fbea5f04bccd28f3aa15a1711548b131504591ac












Issue 985: Clear memory wait condition before raising Exception (#999)
2017-03-02T19:27:07+00:00

Dana Powers
dana.powers@gmail.com

2017-03-02T19:27:07+00:00

a22ea165649b3510d770243f6f3809d598cb4f81












Instrument bufferpool-wait-ratio metric in KafkaProducer
2016-08-04T20:11:20+00:00

Dana Powers
dana.powers@gmail.com

2016-08-04T19:54:53+00:00

025b69ef4ae22d1677904e99f924b9ef5a096e75












Avoid buffer overread when compressing messageset in KafkaProducer
2016-07-17T19:08:57+00:00

Dana Powers
dana.powers@gmail.com

2016-07-17T19:08:57+00:00

d179a3f62e7d225b087290b51f3bc387aa9d434b












 KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770 / #594)
2016-07-17T18:44:01+00:00

Dana Powers
dana.powers@gmail.com

2016-07-17T18:44:01+00:00

68c8a4a276237488fba1495fcec43b572a80289c












Add initial producer-sender metrics
2016-07-16T21:05:49+00:00

Dana Powers
dana.powers@gmail.com

2016-07-11T04:36:41+00:00

c34d13879641d27cceb9403a4e6617152dfda0f3












Fix bug causing KafkaProducer to double-compress message batches on retry
2016-07-15T03:43:03+00:00

Dana Powers
dana.powers@gmail.com

2016-07-13T16:15:57+00:00

ca9d2fabc352f5b6f2709295df7382f5dd7bfc97












Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)
2016-05-23T00:14:03+00:00

Dana Powers
dana.powers@gmail.com

2016-05-23T00:14:03+00:00

1d4251a9efa4c5466ba5095f3ba199bf082a72b5

* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility
* lz4f does not support easy incremental decompression - raise RuntimeError
* Update lz4 codec tests





* LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility
* lz4f does not support easy incremental decompression - raise RuntimeError
* Update lz4 codec tests







KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets
2016-05-22T16:51:37+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T07:31:16+00:00

795cb9b29fa05d4425f807f54dfa639c125fc0dd