code: def need_offset_reset(self, partition, offset_reset_strategy=None):
          
          if offset_reset_strategy is None:
              offset_reset_strategy = self._default_offset_reset_strategy
          self.assignment[partition].await_reset(offset_reset_strategy)
docs: Mark partition for offset reset using specified or default strategy.
  
          Arguments:
              partition (TopicPartition): partition to mark
              offset_reset_strategy (OffsetResetStrategy, optional)