diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-06-06 20:10:20 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-06-06 20:10:20 -0700 |
| commit | f32009cef42e8ca706c661da209107e4513899da (patch) | |
| tree | c2eb33cb630d0c698796f3f5e404cb0ec7d3b40d /docs/usage.rst | |
| parent | 87bea900df341ddc2431569bdc329d069b6c5c61 (diff) | |
| parent | 1d5f4b1f889737ef3ba04d8303a02a4957a2d183 (diff) | |
| download | kafka-python-f32009cef42e8ca706c661da209107e4513899da.tar.gz | |
Merge pull request #388 from dpkp/331_fixups
async producer fixups
Diffstat (limited to 'docs/usage.rst')
| -rw-r--r-- | docs/usage.rst | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/docs/usage.rst b/docs/usage.rst index 150d121..cdacfdc 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -47,7 +47,7 @@ SimpleProducer # 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, batch_send=True, + producer = SimpleProducer(kafka, async=True, batch_send_every_n=20, batch_send_every_t=60) |