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

Class RemoteLogSegmentMetadataUpdate

java.lang.Object

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

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

@InterfaceStability.Evolving
public class RemoteLogSegmentMetadataUpdate
extends RemoteLogMetadata

It describes the metadata update about the log segment in the remote storage. This is currently used to update the state of the remote log segment by using RemoteLogMetadataManager.updateRemoteLogSegmentMetadata(RemoteLogSegmentMetadataUpdate). This also includes the timestamp of this event.

Constructor Summary

Constructors

Constructor and Description
RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId remoteLogSegmentId, long eventTimestampMs, Optional<RemoteLogSegmentMetadata.CustomMetadata> customMetadata, RemoteLogSegmentState state, int brokerId)

Method Summary

Modifier and Type	Method and Description
Optional<RemoteLogSegmentMetadata.CustomMetadata>	customMetadata()
boolean	equals(Object o)
int	hashCode()
RemoteLogSegmentId	remoteLogSegmentId()
RemoteLogSegmentState	state() It represents the state of the remote log segment.
TopicIdPartition	topicIdPartition()
String	toString()

Methods inherited from class org.apache.kafka.server.log.remote.storage.RemoteLogMetadata

brokerId, eventTimestampMs

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RemoteLogSegmentMetadataUpdate

public RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId remoteLogSegmentId,
                                      long eventTimestampMs,
                                      Optional<RemoteLogSegmentMetadata.CustomMetadata> customMetadata,
                                      RemoteLogSegmentState state,
                                      int brokerId)

Parameters:

remoteLogSegmentId - Universally unique remote log segment id.

eventTimestampMs - Epoch time in milli seconds at which the remote log segment is copied to the remote tier storage.

customMetadata - Custom metadata.

state - State of the remote log segment.

brokerId - Broker id from which this event is generated.

Method Detail

remoteLogSegmentId

public RemoteLogSegmentId remoteLogSegmentId()

Returns:

Universally unique id of this remote log segment.

customMetadata

public Optional<RemoteLogSegmentMetadata.CustomMetadata> customMetadata()

Returns:

Custom metadata.

state

public RemoteLogSegmentState state()

It represents the state of the remote log segment. It can be one of the values of RemoteLogSegmentState.

topicIdPartition

public TopicIdPartition topicIdPartition()

Specified by:

topicIdPartition in class RemoteLogMetadata

Returns:

TopicIdPartition for which this event is generated.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object