| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Merge branch 'master' into prod-windows | Mahendra M | 2013-10-08 | 1 | -10/+18 |
| |\ | | | | | | | | | Conflicts: kafka/producer.py | ||||
| | * | make changes to be more fault tolerant: clean up connections, brokers, ↵ | Jim Lim | 2013-10-04 | 1 | -10/+18 |
| | | | | | | | | | | | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception | ||||
| * | | Ensure that async producer works in windows. Fixes #46 | Mahendra M | 2013-10-07 | 1 | -2/+13 |
| |/ | | | | | | | | | | | | | | | As per the multiprocessing module's documentation, the objects passed to the Process() class must be pickle-able in Windows. So, the Async producer did not work in windows. To fix this we have to ensure that code which uses multiprocessing has to follow certain rules * The target=func should not be a member function * We cannot pass objects like socket() to multiprocessing This ticket fixes these issues. For KafkaClient and KafkaConnection objects, we make copies of the object and reinit() them inside the child processes. | ||||
| * | flake8 pass (pep8 and pyflakes) | mrtheb | 2013-10-03 | 1 | -6/+14 |
| | | |||||
| * | 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 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |