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

Class RemotePartitionDeleteMetadata

java.lang.Object

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

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

@Evolving
public class RemotePartitionDeleteMetadata
extends RemoteLogMetadata

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

Constructors

Constructor	Description
RemotePartitionDeleteMetadata(TopicIdPartition topicIdPartition, RemotePartitionDeleteState state, long eventTimestampMs, int brokerId)	Creates an instance of this class with the given metadata.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
RemotePartitionDeleteState	state()	It represents the state of the remote partition.
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

getClass, notify, notifyAll, wait, wait, wait

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

public TopicIdPartition topicIdPartition()

Specified by:

topicIdPartition in class RemoteLogMetadata

Returns:

TopicIdPartition for which this event is meant for.

state

public RemotePartitionDeleteState state()

It represents the state of the remote partition. It can be one of the values of RemotePartitionDeleteState.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object