diff options
author | Mahendra M <mahendra.m@gmail.com> | 2013-09-26 03:23:22 -0700 |
---|---|---|
committer | Mahendra M <mahendra.m@gmail.com> | 2013-09-26 03:23:22 -0700 |
commit | 2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3 (patch) | |
tree | c1f45954a4a578f5ce2a1a00960f499d4fc92ace | |
parent | c0d2cac66940bf477c008e65c9d2bbcd79f030a0 (diff) | |
parent | 3e68f9403883ce488df4a743c91abfd784219bf9 (diff) | |
download | kafka-python-2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3.tar.gz |
Merge pull request #47 from StevenLeRoux/master
Update README.md
-rw-r--r-- | README.md | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -91,7 +91,7 @@ producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner) ## Multiprocess consumer ```python -from kafka.consume import MultiProcessConsumer +from kafka.consumer import MultiProcessConsumer # This will split the number of partitions among two processes consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2) |