'Mark partition for offset reset using specified or default strategy.
Arguments:
partition (TopicPartition): partition to mark
offset_reset_strategy (OffsetResetStrategy, optional)'

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)
