diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-05 23:22:37 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 19:27:56 -0700 |
| commit | 1d5f4b1f889737ef3ba04d8303a02a4957a2d183 (patch) | |
| tree | c2eb33cb630d0c698796f3f5e404cb0ec7d3b40d /kafka/client.py | |
| parent | 2ba22bf4cebf5e25351816b38cd3cb70e2ea4cb8 (diff) | |
| download | kafka-python-1d5f4b1f889737ef3ba04d8303a02a4957a2d183.tar.gz | |
Add async_stop_timeout parameter to tune how long to let the producer
keep trying to send messages before timing out.
Log an error if async producer was stopped before all messages sent.
Diffstat (limited to 'kafka/client.py')
0 files changed, 0 insertions, 0 deletions