@crochet.wait_for(timeout=180.0)
    @defer.inlineCallbacks
    def save(self):

        yield self.async_deep_save()
Seek to the oldest available offset for partitions.
dataset/ETHPy150Open roglew/pappy-proxy/pappyproxy/http.py/Request.save--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.seek_to_beginning