org.apache.kafka.clients.producer
Class RecordMetadata

java.lang.Object
  org.apache.kafka.clients.producer.RecordMetadata

public final class RecordMetadata
extends java.lang.Object

The metadata for a record that has been acknowledged by the server

Constructor Summary

RecordMetadata(TopicPartition topicPartition, long baseOffset, long relativeOffset)

Method Summary

long	offset() The offset of the record in the topic/partition.
int	partition() The partition the record was sent to
java.lang.String	topic() The topic the record was appended to

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordMetadata

public RecordMetadata(TopicPartition topicPartition,
                      long baseOffset,
                      long relativeOffset)

Method Detail

offset

public long offset()

The offset of the record in the topic/partition.

topic

public java.lang.String topic()

The topic the record was appended to

partition

public int partition()

The partition the record was sent to