<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def need_offset_reset(self, partition, offset_reset_strategy=None):
 """Mark partition for offset reset using specified or default strategy. Arguments: partition (TopicPartition):
 partition to mark offset_reset_strategy (OffsetResetStrategy, optional) """

        if offset_reset_strategy is None:
            offset_reset_strategy = self._default_offset_reset_strategy
        self.assignment[partition].await_reset(offset_reset_strategy)