diff options
| -rw-r--r-- | kafka/consumer/fetcher.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/group.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 8f25561..1593018 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -377,7 +377,7 @@ class Fetcher(six.Iterator): # fetch multiple partitions in bulk when they are on the same broker self.init_fetches() - def __iter__(self): + def __iter__(self): # pylint: disable=non-iterator-returned return self def __next__(self): diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index fe94d86..0293b4c 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -634,7 +634,7 @@ class KafkaConsumer(six.Iterator): if time.time() > timeout: break - def __iter__(self): + def __iter__(self): # pylint: disable=non-iterator-returned return self def __next__(self): |