diff options
Diffstat (limited to 'kafka/producer.py')
| -rw-r--r-- | kafka/producer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index 06e468d..5f23285 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -112,7 +112,7 @@ class Producer(object): try: self.client.send_produce_request(reqs, acks=self.req_acks, timeout=self.ack_timeout) - except Exception as exp: + except Exception: log.error("Error sending message", exc_info=sys.exc_info()) def send_messages(self, partition, *msg): |