From 4f8d9fa9dcbffb961b546465e51326dafeb2e6c1 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Fri, 18 Mar 2016 11:25:59 -0700
Subject: Add producer.flush() to usage docs

---
 README.rst | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'README.rst')

diff --git a/README.rst b/README.rst
index 782aba0..8b40519 100644
--- a/README.rst
+++ b/README.rst
@@ -76,9 +76,13 @@ for more details.
 
 >>> from kafka import KafkaProducer
 >>> producer = KafkaProducer(bootstrap_servers='localhost:1234')
->>> producer.send('foobar', b'some_message_bytes')
+>>> for _ in range(100):
+...     producer.send('foobar', b'some_message_bytes')
 
->>> # Blocking send
+>>> # Block until all pending messages are sent
+>>> producer.flush()
+
+>>> # Block until a single message is sent (or timeout)
 >>> producer.send('foobar', b'another_message').get(timeout=60)
 
 >>> # Use a key for hashed-partitioning
-- 
cgit v1.2.1