diff options
author | Mahendra M <mahendra.m@gmail.com> | 2013-06-13 14:43:23 +0530 |
---|---|---|
committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-13 14:43:23 +0530 |
commit | 0723cf8beca7ff6433c79ca04ad1945b00eea6d1 (patch) | |
tree | 1af748932ca319bbe040d3aa1f73604701d5f2ed | |
parent | d3cf18a9fb961f8c640bd2ff0384b9a66ae179bb (diff) | |
download | kafka-python-0723cf8beca7ff6433c79ca04ad1945b00eea6d1.tar.gz |
Better examples in README
-rw-r--r-- | README.md | 5 |
1 files changed, 4 insertions, 1 deletions
@@ -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 |