def rollback(self):
        self.logger.info("Rolling back context: %s", self.initial_offsets)
        self.update_consumer_offsets(self.initial_offsets)
Rollback this context:
dataset/ETHPy150Open dpkp/kafka-python/kafka/context.py/OffsetCommitContext.rollback