Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Add optional timeout parameter to KafkaProducer.flush() | Dana Powers | 2016-03-13 | 1 | -2/+2 |
* | Some attributes may not exist in __del__ if we failed assertions | Dana Powers | 2016-02-18 | 1 | -1/+1 |
* | Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optional | Dana Powers | 2016-02-17 | 1 | -4/+6 |
* | Cleanup docstring nested indent (acks values) | Dana Powers | 2016-02-15 | 1 | -9/+10 |
* | Cleaner event handling in _wait_on_metadata | Dana Powers | 2016-02-15 | 1 | -15/+9 |
* | Remove unused internal sender lock | Dana Powers | 2016-02-15 | 1 | -3/+2 |
* | Revisit _wait_on_metadata to address timeout and error handling (Issue 539) | Dana Powers | 2016-02-15 | 1 | -20/+19 |
* | Add support for LZ4 compressed messages using python-lz4 module | Dana Powers | 2016-01-25 | 1 | -1/+1 |
* | Implement new KafkaProducer, mimicing java client interface / design | Dana Powers | 2016-01-24 | 1 | -0/+496 |