summaryrefslogtreecommitdiff
path: root/README.md
diff options
context:
space:
mode:
Diffstat (limited to 'README.md')
-rw-r--r--README.md12
1 files changed, 12 insertions, 0 deletions
diff --git a/README.md b/README.md
index 8b57172..dbdb295 100644
--- a/README.md
+++ b/README.md
@@ -41,6 +41,18 @@ for message in consumer:
kafka.close()
```
+## Keyed messages
+from kafka.client import KafkaClient
+from kafka.producer import KeyedProducer
+from kafka.partitioner import HashedPartitioner, RoundRobinPartitioner
+
+kafka = KafkaClient("localhost", 9092)
+
+producer = KeyedProducer(kafka, "my-topic", partitioner=HashedPartitioner)
+producer.send("key1", "some message")
+producer.send("key2", "this methode")
+
+
## Low level
```python