diff options
author | Mahendra M <mahendra.m@gmail.com> | 2013-06-28 13:59:06 +0530 |
---|---|---|
committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-28 13:59:06 +0530 |
commit | c13ee1df6ab2900ffe0bd48e6376993c0d312a70 (patch) | |
tree | 031a5fbf46c8b26e54aad3c984ec6cd31f63998f /README.md | |
parent | 7b2a08faed84296221164bcaca15af08dbb88581 (diff) | |
download | kafka-python-c13ee1df6ab2900ffe0bd48e6376993c0d312a70.tar.gz |
Fix cases of single partition
Diffstat (limited to 'README.md')
-rw-r--r-- | README.md | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -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) |