code: def await_reset(self, strategy):
      self.awaiting_reset = True
      self.reset_strategy = strategy
      self._position = None
      self.last_offset_from_message_batch = None
      self.has_valid_position = False
  
imports: from __future__ import absolute_import
  import abc
  import logging
  import re
  from kafka.vendor import six
  from kafka.errors import IllegalStateError
  from kafka.protocol.offset import OffsetResetStrategy
  from kafka.structs import OffsetAndMetadata
label_desc: Use image node_id 4 for calling the TopicPartitionState obj's underlying member method code with example usage: obj.await_reset(strategy) without return types