Merge branch 'issue-35'

Conflicts:
	kafka/__init__.py
	kafka/consumer.py
	test/test_integration.py

1 files changed, 18 insertions, 0 deletions

diff --git a/README.md b/README.md
index 829fab2..19e9a42 100644
--- a/README.md
+++ b/README.md
@@ -89,6 +89,24 @@ producer.send("key2", "this methode")
 producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
 ```
 
+## Multiprocess consumer
+```python
+from kafka.consume import MultiProcessConsumer
+
+# This will split the number of partitions among two processes
+consumer = MultiProcessConsumer(kafka, "my-topic", "my-group", num_procs=2)
+
+# This will spawn processes such that each handles 2 partitions max
+consumer = MultiProcessConsumer(kafka, "my-topic", "my-group",
+                                partitions_per_proc=2)
+
+for message in consumer:
+    print(message)
+
+for message in consumer.get_messages(count=5, block=True, timeout=4):
+    print(message)
+```
+
 ## Low level
 
 ```python