Add producer.flush() to usage docs

1 files changed, 6 insertions, 2 deletions

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