diff options
author | Steven Le Roux <steven@le-roux.info> | 2013-09-26 18:08:44 +0200 |
---|---|---|
committer | Steven Le Roux <steven@le-roux.info> | 2013-09-26 18:08:44 +0200 |
commit | 3194d556420de6fe10ada76402d0eac573dadbd8 (patch) | |
tree | 590176981be3a276dab12e47496494267da3350f | |
parent | 3e68f9403883ce488df4a743c91abfd784219bf9 (diff) | |
download | kafka-python-3194d556420de6fe10ada76402d0eac573dadbd8.tar.gz |
Update README.md
Small fixes in ## Multiprocess consumer example.
-rw-r--r-- | README.md | 7 |
1 files changed, 5 insertions, 2 deletions
@@ -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: |