openstack/deb-python-kafka
Code Issues Proposed changes

Use log exception for metadata failure in async producer

Browse Source
This commit is contained in:
Dana Powers
2016-01-01 22:57:08 -08:00
parent cb1b52f705
commit eab5064929
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/producer/base.py
View File

@@ -196,8 +196,8 @@ def _send_upstream(queue, client, codec, batch_time, batch_size,
log.warn('Async producer forcing metadata refresh metadata before retrying') log.warn('Async producer forcing metadata refresh metadata before retrying')
try: try:
client.load_metadata_for_topics() client.load_metadata_for_topics()
except Exception as e: except Exception:
log.error("Async producer couldn't reload topic metadata. Error: `%s`", e.message) log.exception("Async producer couldn't reload topic metadata.")
# Apply retry limit, dropping messages that are over # Apply retry limit, dropping messages that are over
request_tries = dict( request_tries = dict(