code: def __init__(self, topic_partition):
      super(FutureProduceResult, self).__init__()
      self.topic_partition = topic_partition
      self._latch = threading.Event()
  
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 1 to create a new FutureProduceResult object from inherited base classes: Future with example: obj = FutureProduceResult(topic_partition)