diff options
| -rw-r--r-- | kafka/consumer.py | 2 | ||||
| -rw-r--r-- | kafka/producer.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer.py b/kafka/consumer.py index 3efffdf..a97e8c0 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -299,7 +299,7 @@ class SimpleConsumer(Consumer): while count > 0: try: messages.append(next(iterator)) - except StopIteration as exp: + except StopIteration: break count -= 1 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): |