diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-01 22:57:08 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-01 22:57:08 -0800 |
| commit | eab50649297033a7c0883fb30b7f6e0ade77b603 (patch) | |
| tree | 3c5de2d030dc4da3d9ef1bdce10c91c55b51fca7 | |
| parent | cb1b52f7056591d3964c7e4ba12c8fb21085b135 (diff) | |
| download | kafka-python-eab50649297033a7c0883fb30b7f6e0ade77b603.tar.gz | |
Use log exception for metadata failure in async producer
| -rw-r--r-- | kafka/producer/base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 4972cd4..d733172 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -196,8 +196,8 @@ def _send_upstream(queue, client, codec, batch_time, batch_size, log.warn('Async producer forcing metadata refresh metadata before retrying') try: client.load_metadata_for_topics() - except Exception as e: - log.error("Async producer couldn't reload topic metadata. Error: `%s`", e.message) + except Exception: + log.exception("Async producer couldn't reload topic metadata.") # Apply retry limit, dropping messages that are over request_tries = dict( |