summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
...
* don't forget to call superclass __init__Vetoshkin Nikita2013-10-031-0/+1
|
* style: fix camelCase variable names againVetoshkin Nikita2013-10-031-2/+2
|
* style: fix camelCase variable names once moreVetoshkin Nikita2013-10-031-3/+3
|
* style: fix camelCase variable namesVetoshkin Nikita2013-10-031-2/+2
| | | | | | Conflicts: kafka/util.py
* style: use triple quotes for docstringsVetoshkin Nikita2013-10-031-2/+6
|
* style: fix whitespacesVetoshkin Nikita2013-10-031-0/+2
|
* Merge branch 'issue-35'David Arthur2013-07-261-0/+9
|\ | | | | | | | | | | | | Conflicts: kafka/__init__.py kafka/consumer.py test/test_integration.py
| * Re-init the sockets in the new processMahendra M2013-06-271-0/+9
| |
* | 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