summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-09-26 03:23:22 -0700
committerMahendra M <mahendra.m@gmail.com>2013-09-26 03:23:22 -0700
commit2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3 (patch)
treec1f45954a4a578f5ce2a1a00960f499d4fc92ace
parentc0d2cac66940bf477c008e65c9d2bbcd79f030a0 (diff)
parent3e68f9403883ce488df4a743c91abfd784219bf9 (diff)
downloadkafka-python-2f6bcc2b8cddf2baa3eeef16eacfc42a9d0410f3.tar.gz
Merge pull request #47 from StevenLeRoux/master
Update README.md
-rw-r--r--README.md2
1 files changed, 1 insertions, 1 deletions
diff --git a/README.md b/README.md
index 9d4bfd1..5780db9 100644
--- a/README.md
+++ b/README.md
@@ -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)