diff --git a/aiokafka/producer/sender.py b/aiokafka/producer/sender.py index d9b57ba..85272ed 100644 --- a/aiokafka/producer/sender.py +++ b/aiokafka/producer/sender.py @@ -175,7 +175,7 @@ def _sender_routine(self): except (ProducerFenced, OutOfOrderSequenceNumber, TransactionalIdAuthorizationFailed): raise - except Exception: # pragma: no cover + except Exception as exc: # pragma: no cover log.error("Unexpected error in sender routine", exc_info=True) if self._on_irrecoverable_error: res = self._on_irrecoverable_error(exc)