| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | flake8 pass (pep8 and pyflakes) | mrtheb | 2013-10-03 | 1 | -8/+11 |
| | | |||||
| * | Fix #44 Add missing exception classv0.8.0 | David Arthur | 2013-09-24 | 1 | -1/+1 |
| | | | | | Also move the exceptions to common instead of util | ||||
| * | PEP8-ify most of the files | Mahendra M | 2013-05-29 | 1 | -31/+65 |
| | | | | | consumer.py and conn.py will be done later after pending merges | ||||
| * | Refactoring a bit, cleanup for 0.8 | David Arthur | 2013-04-02 | 1 | -0/+2 |
| | | | | | Marking some stuff as not compatible for 0.8 (will be added in 0.8.1) | ||||
| * | Adding client_fetch_size to queue interface | David Arthur | 2013-04-02 | 1 | -3/+34 |
| | | | | | Also more docs | ||||
| * | Add some docs and KafkaQueue config | David Arthur | 2012-11-19 | 1 | -19/+47 |
| | | | | | Ref #8 | ||||
| * | Add a Queue-like producer/consumer | David Arthur | 2012-11-19 | 1 | -0/+119 |
| Creates a producer process and one consumer process per partition. Uses `multiprocessing.Queue` for communication between the parent process and the producer/consumers. ```python kafka = KafkaClient("localhost", 9092) q = KafkaQueue(kafka, client="test-queue", partitions=[0,1]) q.put("test") q.get() q.close() kafka.close() ``` Ref #8 | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |