Update README with examples

1 files changed, 11 insertions, 0 deletions

diff --git a/README.md b/README.md
index 6fb199f..a7fbd6c 100644
--- a/README.md
+++ b/README.md
@@ -54,6 +54,17 @@ if response:
     print(response[0].error)
     print(response[0].offset)
 
+# To send messages in batch. You can use any of the available
+# producers for doing this. The following producer will collect
+# messages in batch and send them to Kafka after 20 messages are
+# collected or every 60 seconds
+# Notes:
+# * If the producer dies before the messages are sent, there will be losses
+# * Call producer.stop() to send the messages and cleanup
+producer = SimpleProducer(kafka, "my-topic", batch_send=True,
+                          batch_send_every_n=20,
+                          batch_send_every_t=60)
+
 # To consume messages
 consumer = SimpleConsumer(kafka, "my-group", "my-topic")
 for message in consumer: