docs: def reset_offsets_if_needed(self, partitions):
          """Lookup and set offsets for any partitions which are awaiting an
          explicit reset.
  
          Arguments:
              partitions (set of TopicPartitions): the partitions to reset
          """
          for tp in partitions:
              # TODO: If there are several offsets to reset, we could submit offset requests in parallel
              if self._subscriptions.is_assigned(tp) and self._subscriptions.is_offset_reset_needed(tp):
                  self._reset_offset(tp)