def handle_out_of_range(self):
        self.logger.info("Seeking beginning of partition on out of range error")
        self.consumer.seek(0, 0)
Handle out of range condition by seeking to the beginning of valid
dataset/ETHPy150Open dpkp/kafka-python/kafka/context.py/OffsetCommitContext.handle_out_of_range