summaryrefslogtreecommitdiff
path: root/kafka/consumer.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/consumer.py')
-rw-r--r--kafka/consumer.py2
1 files changed, 1 insertions, 1 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