'Rollback this context:
-  Position the consumer at the initial offsets.'

def rollback(self):

    self.logger.info('Rolling    back    context:    %s', self.initial_offsets)
    self.update_consumer_offsets(self.initial_offsets)
