code: def rollback(self):
          
          self.logger.info("Rolling back context: %s", self.initial_offsets)
          self.update_consumer_offsets(self.initial_offsets)
docs: Rollback this context:
  
           -  Position the consumer at the initial offsets.