summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2013-09-26 09:44:20 -0700
committerDavid Arthur <mumrah@gmail.com>2013-09-26 09:44:20 -0700
commit2ed76380445366c234acf928124dcbb35b008f45 (patch)
tree590176981be3a276dab12e47496494267da3350f
parent2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3 (diff)
parent3194d556420de6fe10ada76402d0eac573dadbd8 (diff)
downloadkafka-python-2ed76380445366c234acf928124dcbb35b008f45.tar.gz
Merge pull request #48 from StevenLeRoux/master
Update README.md
-rw-r--r--README.md7
1 files changed, 5 insertions, 2 deletions
diff --git a/README.md b/README.md
index 5780db9..a3bb8f6 100644
--- a/README.md
+++ b/README.md
@@ -91,13 +91,16 @@ producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
## Multiprocess consumer
```python
+from kafka.client import KafkaClient
from kafka.consumer import MultiProcessConsumer
+kafka = KafkaClient("localhost", 9092)
+
# This will split the number of partitions among two processes
-consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2)
+consumer = MultiProcessConsumer(kafka, "my-group", "my-topic", num_procs=2)
# This will spawn processes such that each handles 2 partitions max
-consumer = MultiProcessConsumer(kafka, "my-topic", "my-group",
+consumer = MultiProcessConsumer(kafka, "my-group", "my-topic",
partitions_per_proc=2)
for message in consumer: