diff options
author | Steven Le Roux <steven@le-roux.info> | 2013-09-26 12:00:46 +0200 |
---|---|---|
committer | Steven Le Roux <steven@le-roux.info> | 2013-09-26 12:00:46 +0200 |
commit | 3e68f9403883ce488df4a743c91abfd784219bf9 (patch) | |
tree | c1f45954a4a578f5ce2a1a00960f499d4fc92ace | |
parent | c0d2cac66940bf477c008e65c9d2bbcd79f030a0 (diff) | |
download | kafka-python-3e68f9403883ce488df4a743c91abfd784219bf9.tar.gz |
Update README.md
correct typo in readme example
-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) |