Package 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
@Evolving public abstract class RemoteLogMetadata extends Object
Base class for remote log metadata objects like RemoteLogSegmentMetadata, RemoteLogSegmentMetadataUpdate, and RemotePartitionDeleteMetadata.

  • Constructor Details

    • RemoteLogMetadata

      protected RemoteLogMetadata(int brokerId, long eventTimestampMs)

  • Method Details

    • 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.