diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-31 11:21:44 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-31 18:12:20 -0800 |
| commit | 9258bb4ba5e66565f74a691640c5c11f3b58bbd8 (patch) | |
| tree | e554cf7649006fac2aed495c21db9a75c9c87994 | |
| parent | 89e22a0e457ac4f6ddbf237ff32e5a278c2c02ed (diff) | |
| download | kafka-python-9258bb4ba5e66565f74a691640c5c11f3b58bbd8.tar.gz | |
Remove some unused bits from kafka.consumer.group
| -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 |