diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2018-10-26 22:53:03 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-10-26 22:55:52 -0700 |
| commit | 8791f0558fc103df43a2d7ab214904ad9a15f147 (patch) | |
| tree | 161a28f7caf355ff72eebaaff8eab3db1f4fda22 | |
| parent | b54607fbb88507e692f63c5c547742009f6bcaa8 (diff) | |
| download | kafka-python-8791f0558fc103df43a2d7ab214904ad9a15f147.tar.gz | |
Stop using deprecated log.warn()
I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd.
| -rw-r--r-- | kafka/producer/base.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 956cef6..1da74c8 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -83,7 +83,7 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, try: client.reinit() except Exception as e: - log.warn('Async producer failed to connect to brokers; backoff for %s(ms) before retrying', retry_options.backoff_ms) + log.warning('Async producer failed to connect to brokers; backoff for %s(ms) before retrying', retry_options.backoff_ms) time.sleep(float(retry_options.backoff_ms) / 1000) else: break @@ -189,12 +189,12 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, # doing backoff before next retry if retry_state['do_backoff'] and retry_options.backoff_ms: - log.warn('Async producer backoff for %s(ms) before retrying', retry_options.backoff_ms) + log.warning('Async producer backoff for %s(ms) before retrying', retry_options.backoff_ms) time.sleep(float(retry_options.backoff_ms) / 1000) # refresh topic metadata before next retry if retry_state['do_refresh']: - log.warn('Async producer forcing metadata refresh metadata before retrying') + log.warning('Async producer forcing metadata refresh metadata before retrying') try: client.load_metadata_for_topics() except Exception: |