diff options
| author | Vetoshkin Nikita <nekto0n@yandex-team.ru> | 2013-10-03 18:26:34 +0400 |
|---|---|---|
| committer | David Arthur <mumrah@gmail.com> | 2013-10-03 19:37:14 -0400 |
| commit | 11f22fb3d74b69f98324ac82b786d4dedefe2dc5 (patch) | |
| tree | de2ff7afe2310ab980f3835dd041706ef8dafae3 | |
| parent | 7ac75c575c446029a706ce922e646f95805c776e (diff) | |
| download | kafka-python-11f22fb3d74b69f98324ac82b786d4dedefe2dc5.tar.gz | |
remove unused exception instance variables
| -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): |