Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | | Make the default case as 'ack on local write' | Mahendra M | 2013-06-20 | 1 | -1/+1 | |
|/ | | | | | | | Also, ensure that the case of 'no-acks' works fine In conn.send(), do not wait for the response. Wait for it only on conn.recv(). This behaviour is fine now since the connection is not shared among consumer threads etc. | |||||
* | Fix auto-commit issues with multi-threading | Mahendra M | 2013-06-03 | 1 | -1/+2 | |
| | ||||||
* | Adding a debug statement | David Arthur | 2013-05-28 | 1 | -1/+2 | |
| | ||||||
* | Update kafka-src to latest 0.8 | David Arthur | 2013-04-02 | 1 | -1/+2 | |
| | | | | Fix a broken test (100k was too much to send in one batch) | |||||
* | Big code re-org | David Arthur | 2013-04-02 | 1 | -0/+85 | |