Class RemotePartitionDeleteMetadata
java.lang.Object
org.apache.kafka.server.log.remote.storage.RemoteLogMetadata
org.apache.kafka.server.log.remote.storage.RemotePartitionDeleteMetadata
This class represents the metadata about the remote partition. It can be created/updated with
RemoteLogMetadataManager.putRemotePartitionDeleteMetadata(RemotePartitionDeleteMetadata)
.
Possible state transitions are mentioned at RemotePartitionDeleteState
.-
Constructor Summary
ConstructorDescriptionRemotePartitionDeleteMetadata
(TopicIdPartition topicIdPartition, RemotePartitionDeleteState state, long eventTimestampMs, int brokerId) Creates an instance of this class with the given metadata. -
Method Summary
Methods inherited from class org.apache.kafka.server.log.remote.storage.RemoteLogMetadata
brokerId, eventTimestampMs
-
Constructor Details
-
RemotePartitionDeleteMetadata
public RemotePartitionDeleteMetadata(TopicIdPartition topicIdPartition, RemotePartitionDeleteState state, long eventTimestampMs, int brokerId) Creates an instance of this class with the given metadata.- Parameters:
topicIdPartition
- topic partition for which this event is meant for.state
- State of the remote topic partition.eventTimestampMs
- Epoch time in milli seconds at which this event is occurred.brokerId
- Id of the broker in which this event is raised.
-
-
Method Details
-
topicIdPartition
- Specified by:
topicIdPartition
in classRemoteLogMetadata
- Returns:
- TopicIdPartition for which this event is meant for.
-
state
It represents the state of the remote partition. It can be one of the values ofRemotePartitionDeleteState
. -
toString
-
equals
-
hashCode
public int hashCode()
-