diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-13 17:51:26 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-13 17:51:26 +0530 |
| commit | 337127a77dc749224bd7645893950ed90f76f134 (patch) | |
| tree | 1356494238270b7f23df2faa8dc7a10ba75eda18 /kafka/client.py | |
| parent | 77b8301e253774e09d13ff6b7c132fd51e6d9091 (diff) | |
| download | kafka-python-337127a77dc749224bd7645893950ed90f76f134.tar.gz | |
Support for async producer
The Java/Scala Kafka client supports a mechanism for sending
messages asynchronously by using a queue and a thread.
Messages are put on the queue and the worker thread keeps sending
it to the broker.
This ticket implements this feature in python
We use multiprocessing instead of threads to send the messages
Diffstat (limited to 'kafka/client.py')
0 files changed, 0 insertions, 0 deletions