summaryrefslogtreecommitdiff
path: root/README.md
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-06-28 13:59:06 +0530
committerMahendra M <mahendra.m@gmail.com>2013-06-28 13:59:06 +0530
commitc13ee1df6ab2900ffe0bd48e6376993c0d312a70 (patch)
tree031a5fbf46c8b26e54aad3c984ec6cd31f63998f /README.md
parent7b2a08faed84296221164bcaca15af08dbb88581 (diff)
downloadkafka-python-c13ee1df6ab2900ffe0bd48e6376993c0d312a70.tar.gz
Fix cases of single partition
Diffstat (limited to 'README.md')
-rw-r--r--README.md2
1 files changed, 2 insertions, 0 deletions
diff --git a/README.md b/README.md
index 03b8d3c..83ec447 100644
--- a/README.md
+++ b/README.md
@@ -59,6 +59,8 @@ producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
## Multiprocess consumer
```python
+from kafka.consume import MultiProcessConsumer
+
# This will split the number of partitions among two processes
consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2)