openstack/deb-python-kafka
Code Issues Proposed changes

Better examples in README

Browse Source
This commit is contained in:
Mahendra M
2013-06-13 14:43:23 +05:30
parent d3cf18a9fb
commit 0723cf8bec
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
README.md
View File

@@ -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