summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-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)