Class RemoteLogSegmentMetadataUpdate
java.lang.Object
org.apache.kafka.server.log.remote.storage.RemoteLogMetadata
org.apache.kafka.server.log.remote.storage.RemoteLogSegmentMetadataUpdate
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
ConstructorDescriptionRemoteLogSegmentMetadataUpdate
(RemoteLogSegmentId remoteLogSegmentId, long eventTimestampMs, RemoteLogSegmentState state, int brokerId) -
Method Summary
Methods inherited from class org.apache.kafka.server.log.remote.storage.RemoteLogMetadata
brokerId, eventTimestampMs
-
Constructor Details
-
RemoteLogSegmentMetadataUpdate
public RemoteLogSegmentMetadataUpdate(RemoteLogSegmentId remoteLogSegmentId, long eventTimestampMs, 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.state
- State of the remote log segment.brokerId
- Broker id from which this event is generated.
-
-
Method Details
-
remoteLogSegmentId
- Returns:
- Universally unique id of this remote log segment.
-
state
It represents the state of the remote log segment. It can be one of the values ofRemoteLogSegmentState
. -
topicIdPartition
- Specified by:
topicIdPartition
in classRemoteLogMetadata
- Returns:
- TopicIdPartition for which this event is generated.
-
equals
-
hashCode
public int hashCode() -
toString
-