diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-04-22 19:05:18 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:48 +0300 |
| commit | 9eed1698fdcdda7cd8efe7bbee559ccf8baf9e1e (patch) | |
| tree | 134365069b58b0188e6975081a787ae6511f33ab | |
| parent | 91af27c64488a0029e960615d0f10d62532d6616 (diff) | |
| download | kafka-python-9eed1698fdcdda7cd8efe7bbee559ccf8baf9e1e.tar.gz | |
Change backoff message log level
| -rw-r--r-- | kafka/producer/base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index df391f7..03ef2a7 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -115,7 +115,7 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, # doing backoff before next retry if error_type in RETRY_BACKOFF_ERROR_TYPES and retry_options.backoff_ms: - log.warning("Doing backoff for %s(ms)." % retry_options.backoff_ms) + log.info("Doing backoff for %s(ms)." % retry_options.backoff_ms) time.sleep(float(retry_options.backoff_ms) / 1000) # refresh topic metadata before next retry |