diff options
| author | David Arthur <mumrah@gmail.com> | 2012-11-19 10:29:30 -0500 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2012-11-19 20:47:27 -0500 |
| commit | 330ddbca4464f32d31b662eb95b92113e7024323 (patch) | |
| tree | 3869ac9b6e2b0d8718eb5576a3031b73ad315e15 /example.py | |
| parent | 0c61f4467a327e38c9c8701ab680e47a209bab7c (diff) | |
| download | kafka-python-330ddbca4464f32d31b662eb95b92113e7024323.tar.gz | |
Add a Queue-like producer/consumer
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
Diffstat (limited to 'example.py')
0 files changed, 0 insertions, 0 deletions