Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
* | don't forget to call superclass __init__ | Vetoshkin Nikita | 2013-10-03 | 1 | -0/+1 | |
| | ||||||
* | style: fix camelCase variable names again | Vetoshkin Nikita | 2013-10-03 | 1 | -2/+2 | |
| | ||||||
* | style: fix camelCase variable names once more | Vetoshkin Nikita | 2013-10-03 | 1 | -3/+3 | |
| | ||||||
* | style: fix camelCase variable names | Vetoshkin Nikita | 2013-10-03 | 1 | -2/+2 | |
| | | | | | | Conflicts: kafka/util.py | |||||
* | style: use triple quotes for docstrings | Vetoshkin Nikita | 2013-10-03 | 1 | -2/+6 | |
| | ||||||
* | style: fix whitespaces | Vetoshkin Nikita | 2013-10-03 | 1 | -0/+2 | |
| | ||||||
* | Merge branch 'issue-35' | David Arthur | 2013-07-26 | 1 | -0/+9 | |
|\ | | | | | | | | | | | | | Conflicts: kafka/__init__.py kafka/consumer.py test/test_integration.py | |||||
| * | Re-init the sockets in the new process | Mahendra M | 2013-06-27 | 1 | -0/+9 | |
| | | ||||||
* | | 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 | |