Add producer.flush() to usage docs

1 files changed, 6 insertions, 2 deletions

diff --git a/docs/index.rst b/docs/index.rst
index d8f826a..eb8f429 100644
--- a/docs/index.rst
+++ b/docs/index.rst
@@ -74,9 +74,13 @@ client. See `KafkaProducer <apidoc/KafkaProducer.html>`_ 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