Skip to content

Commit 3e68f94

Browse files
committed
Update README.md
correct typo in readme example
1 parent c0d2cac commit 3e68f94

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
9191

9292
## Multiprocess consumer
9393
```python
94-
from kafka.consume import MultiProcessConsumer
94+
from kafka.consumer import MultiProcessConsumer
9595

9696
# This will split the number of partitions among two processes
9797
consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2)

0 commit comments

Comments
 (0)