From 3e68f9403883ce488df4a743c91abfd784219bf9 Mon Sep 17 00:00:00 2001 From: Steven Le Roux Date: Thu, 26 Sep 2013 12:00:46 +0200 Subject: Update README.md correct typo in readme example --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) -- cgit v1.2.1