diff options
| -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 |