org.apache.kafka.server.log.remote.storage

Class RemoteLogMetadata

java.lang.Object

org.apache.kafka.server.log.remote.storage.RemoteLogMetadata

Direct Known Subclasses:

RemoteLogSegmentMetadata, RemoteLogSegmentMetadataUpdate, RemotePartitionDeleteMetadata

@InterfaceStability.Evolving
public abstract class RemoteLogMetadata
extends Object

Base class for remote log metadata objects like RemoteLogSegmentMetadata, RemoteLogSegmentMetadataUpdate, and RemotePartitionDeleteMetadata.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RemoteLogMetadata(int brokerId, long eventTimestampMs)

Method Summary

Modifier and Type	Method and Description
int	brokerId()
long	eventTimestampMs()
abstract TopicIdPartition	topicIdPartition()

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteLogMetadata

protected RemoteLogMetadata(int brokerId,
                            long eventTimestampMs)

Method Detail

eventTimestampMs

public long eventTimestampMs()

Returns:

Epoch time in milli seconds at which this event is occurred.

brokerId

public int brokerId()

Returns:

Broker id from which this event is generated.

topicIdPartition

public abstract TopicIdPartition topicIdPartition()

Returns:

TopicIdPartition for which this event is generated.