diff options
Diffstat (limited to 'docs/usage.rst')
| -rw-r--r-- | docs/usage.rst | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/docs/usage.rst b/docs/usage.rst index d48cc0a..85fc44f 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -87,5 +87,12 @@ KafkaProducer producer = KafkaProducer(value_serializer=lambda m: json.dumps(m).encode('ascii')) producer.send('json-topic', {'key': 'value'}) + # produce asynchronously + for _ in range(100): + producer.send('my-topic', b'msg') + + # block until all async messages are sent + producer.flush() + # configure multiple retries producer = KafkaProducer(retries=5) |