diff options
author | Mahendra M <mahendra.m@gmail.com> | 2013-06-28 13:08:04 +0530 |
---|---|---|
committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-28 13:08:04 +0530 |
commit | 9a557ed0bcb5fa1374ac4314ceff5fa168ec2c71 (patch) | |
tree | c24f5892b06e12f3576517c106e48dc1557d52de | |
parent | 6b76d9d682b2b7c6280dda84dbad07e6d856de0e (diff) | |
download | kafka-python-9a557ed0bcb5fa1374ac4314ceff5fa168ec2c71.tar.gz |
Fix markups
-rw-r--r-- | README.md | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -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) |