diff options
| -rw-r--r-- | kafka/consumer/group.py | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 67e352a..5278214 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -4,10 +4,6 @@ import copy import logging import time -import six - -import kafka.common as Errors - from kafka.client_async import KafkaClient from kafka.consumer.fetcher import Fetcher from kafka.consumer.subscription_state import SubscriptionState @@ -570,7 +566,6 @@ class KafkaConsumer(object): def __iter__(self): while True: - # records = self._poll_once(self.config['request_timeout_ms']) self._coordinator.ensure_coordinator_known() # ensure we have partitions assigned if we expect to |