diff options
author | David Arthur <mumrah@gmail.com> | 2013-09-26 09:44:20 -0700 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-09-26 09:44:20 -0700 |
commit | 2ed76380445366c234acf928124dcbb35b008f45 (patch) | |
tree | 590176981be3a276dab12e47496494267da3350f | |
parent | 2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3 (diff) | |
parent | 3194d556420de6fe10ada76402d0eac573dadbd8 (diff) | |
download | kafka-python-2ed76380445366c234acf928124dcbb35b008f45.tar.gz |
Merge pull request #48 from StevenLeRoux/master
Update README.md
-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: |