code: def _produce_success(self, offset_and_timestamp):
      (
          offset,
          produce_timestamp_ms,
          log_start_offset,
      ) = offset_and_timestamp
  
      # Unpacking from args tuple is minor speed optimization
      (
          relative_offset,
          timestamp_ms,
          checksum,
          serialized_key_size,
          serialized_value_size,
          serialized_header_size,
      ) = self.args
  
      # None is when Broker does not support the API (<0.10) and
      # -1 is when the broker is configured for CREATE_TIME timestamps
      if (
          produce_timestamp_ms is not None
          and produce_timestamp_ms != -1
      ):
          timestamp_ms = produce_timestamp_ms
      if offset != -1 and relative_offset is not None:
          offset += relative_offset
      tp = self._produce_future.topic_partition
      metadata = RecordMetadata(
          tp[0],
          tp[1],
          tp,
          offset,
          timestamp_ms,
          log_start_offset,
          checksum,
          serialized_key_size,
          serialized_value_size,
          serialized_header_size,
      )
      self.success(metadata)
  
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 2 for calling the FutureRecordMetadata obj's underlying member method code with example usage: obj._produce_success(offset_and_timestamp) without return types