code: def get(self, timeout=None):
      if not self.is_done and not self._produce_future.wait(timeout):
          raise Errors.KafkaTimeoutError(
              "Timeout after waiting for %s secs." % (timeout,)
          )
      assert self.is_done
      if self.failed():
          raise self.exception  # pylint: disable-msg=raising-bad-type
      return self.value
  
file_path: kafka-python/kafka/producer/future.py
imports: from __future__ import absolute_import
  import collections
  import threading
  from kafka import errors
  from kafka.future import Future
label_desc: Use image node_id 3 for calling the FutureRecordMetadata obj's underlying member method code with example usage: obj.get(timeout) and returns: self