diff options
| author | Andrew Kowalik <andrew.kowalik@percolate.com> | 2017-05-04 10:46:38 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2017-06-16 23:21:11 -0700 |
| commit | 83f2d322a9fecbe9a0afb6e103f0fbdcf2fd6486 (patch) | |
| tree | b3c619b3dbf8d61b8385613e46e0a549ac6e3ed4 /kafka/producer/kafka.py | |
| parent | bb626dbffba23e4cb20e99e9d48663a436c9ba76 (diff) | |
| download | kafka-python-83f2d322a9fecbe9a0afb6e103f0fbdcf2fd6486.tar.gz | |
raise KafkaTimeoutException when flush times out
Diffstat (limited to 'kafka/producer/kafka.py')
| -rw-r--r-- | kafka/producer/kafka.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py index 3abadcc..57155e5 100644 --- a/kafka/producer/kafka.py +++ b/kafka/producer/kafka.py @@ -554,6 +554,10 @@ class KafkaProducer(object): Arguments: timeout (float, optional): timeout in seconds to wait for completion. + + Raises: + KafkaTimeoutError: failure to flush buffered records within the + provided timeout """ log.debug("Flushing accumulated records in producer.") # trace self._accumulator.begin_flush() |