summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMahendra M <mahendra.m@gmail.com>2013-06-13 14:43:23 +0530
committerMahendra M <mahendra.m@gmail.com>2013-06-13 14:43:23 +0530
commit0723cf8beca7ff6433c79ca04ad1945b00eea6d1 (patch)
tree1af748932ca319bbe040d3aa1f73604701d5f2ed
parentd3cf18a9fb961f8c640bd2ff0384b9a66ae179bb (diff)
downloadkafka-python-0723cf8beca7ff6433c79ca04ad1945b00eea6d1.tar.gz
Better examples in README
-rw-r--r--README.md5
1 files changed, 4 insertions, 1 deletions
diff --git a/README.md b/README.md
index 40b5585..60cc745 100644
--- a/README.md
+++ b/README.md
@@ -49,9 +49,12 @@ from kafka.partitioner import HashedPartitioner, RoundRobinPartitioner
kafka = KafkaClient("localhost", 9092)
-producer = KeyedProducer(kafka, "my-topic", partitioner=HashedPartitioner)
+# HashedPartitioner is default
+producer = KeyedProducer(kafka, "my-topic")
producer.send("key1", "some message")
producer.send("key2", "this methode")
+
+producer = KeyedProducer(kafka, "my-topic", partitioner=RoundRobinPartitioner)
```
## Low level