org.apache.kafka.clients.producer

Class RecordMetadata

java.lang.Object

org.apache.kafka.clients.producer.RecordMetadata

public final class RecordMetadata
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNKNOWN_PARTITION Partition value for record without partition assigned

Constructor Summary

Constructors

Constructor and Description
RecordMetadata(TopicPartition topicPartition, long baseOffset, long relativeOffset) Deprecated.
RecordMetadata(TopicPartition topicPartition, long baseOffset, long relativeOffset, long timestamp, long checksum, int serializedKeySize, int serializedValueSize)

Method Summary

Methods

Modifier and Type	Method and Description
long	checksum() The checksum (CRC32) of the record.
long	offset() The offset of the record in the topic/partition.
int	partition() The partition the record was sent to
int	serializedKeySize() The size of the serialized, uncompressed key in bytes.
int	serializedValueSize() The size of the serialized, uncompressed value in bytes.
long	timestamp() The timestamp of the record in the topic/partition.
String	topic() The topic the record was appended to
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

UNKNOWN_PARTITION

public static final int UNKNOWN_PARTITION

Partition value for record without partition assigned

See Also:

Constant Field Values

Constructor Detail

RecordMetadata

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

Deprecated.

RecordMetadata

public RecordMetadata(TopicPartition topicPartition,
              long baseOffset,
              long relativeOffset,
              long timestamp,
              long checksum,
              int serializedKeySize,
              int serializedValueSize)

Method Detail

offset

public long offset()

The offset of the record in the topic/partition.

timestamp

public long timestamp()

The timestamp of the record in the topic/partition.

checksum

public long checksum()

The checksum (CRC32) of the record.

serializedKeySize

public int serializedKeySize()

The size of the serialized, uncompressed key in bytes. If key is null, the returned size is -1.

serializedValueSize

public int serializedValueSize()

The size of the serialized, uncompressed value in bytes. If value is null, the returned size is -1.

topic

public String topic()

The topic the record was appended to

partition

public int partition()

The partition the record was sent to

toString

public String toString()

Overrides:

toString in class Object