summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-06-28 13:08:04 +0530
committerMahendra M <mahendra.m@gmail.com>2013-06-28 13:08:04 +0530
commit9a557ed0bcb5fa1374ac4314ceff5fa168ec2c71 (patch)
treec24f5892b06e12f3576517c106e48dc1557d52de
parent6b76d9d682b2b7c6280dda84dbad07e6d856de0e (diff)
downloadkafka-python-9a557ed0bcb5fa1374ac4314ceff5fa168ec2c71.tar.gz
Fix markups
-rw-r--r--README.md2
1 files changed, 2 insertions, 0 deletions
diff --git a/README.md b/README.md
index 5449148..d42f2fc 100644
--- a/README.md
+++ b/README.md
@@ -55,8 +55,10 @@ producer.send("key1", "some message")
producer.send("key2", "this methode")
producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
+```
# Multiprocess consumer
+```python
# This will split the number of partitions among two processes
consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2)