def fetch_committed_offsets(self, partitions):
        if not partitions:
            return {}

        while True:
            if self.config['api_version'] >= (0, 8, 2):
                self.ensure_coordinator_known()

            # contact coordinator to fetch committed offsets
            future = self._send_offset_fetch_request(partitions)
            self._client.poll(future=future)

            if future.succeeded():
                return future.value

            if not future.retriable():
                raise future.exception # pylint: disable-msg=raising-bad-type

            time.sleep(self.config['retry_backoff_ms'] / 1000.0)
1 2 4
dataset/ETHPy150Open dpkp/kafka-python/kafka/coordinator/consumer.py/ConsumerCoordinator.fetch_committed_offsets--crossover with--dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/lxml-3.3.6/benchmark/bench_objectify.py/BenchMark.bench_objectpath