summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
...
* | Make the default case as 'ack on local write'Mahendra M2013-06-201-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-threadingMahendra M2013-06-031-1/+2
|
* Adding a debug statementDavid Arthur2013-05-281-1/+2
|
* Update kafka-src to latest 0.8David Arthur2013-04-021-1/+2
| | | | Fix a broken test (100k was too much to send in one batch)
* Big code re-orgDavid Arthur2013-04-021-0/+85