diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-04 13:31:30 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 19:27:55 -0700 |
| commit | 48e278941206815d680b4d4c81d7f1fd2637255c (patch) | |
| tree | fa25bfba16fe1afc0e88ee761314597bddb69a1a /kafka/producer/base.py | |
| parent | 3fdd7b78dcf2c29b72f301eec0bf71e74c1672b3 (diff) | |
| download | kafka-python-48e278941206815d680b4d4c81d7f1fd2637255c.tar.gz | |
PR 331 fixup: log warnings on async producer backoff and metadata refresh
Diffstat (limited to 'kafka/producer/base.py')
| -rw-r--r-- | kafka/producer/base.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 05adb5e..c1bc0c5 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -124,11 +124,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.info("Doing backoff for %s(ms)." % retry_options.backoff_ms) + log.warn('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') client.load_metadata_for_topics() reqs = dict((key, count + 1) |