public class TierTopicInitLeader extends AbstractTierMetadata
Modifier and Type | Field and Description |
---|---|
static byte |
ID |
Constructor and Description |
---|
TierTopicInitLeader(org.apache.kafka.common.TopicPartition topicPartition,
InitLeader init) |
TierTopicInitLeader(org.apache.kafka.common.TopicPartition topicPartition,
int tierEpoch,
java.util.UUID messageId,
int brokerId) |
Modifier and Type | Method and Description |
---|---|
int |
brokerId() |
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.util.UUID |
messageId() |
java.nio.ByteBuffer |
payloadBuffer() |
int |
tierEpoch()
tierEpoch for the tier metadata
|
org.apache.kafka.common.TopicPartition |
topicPartition()
Topic-partition corresponding to this tier metadata.
|
java.lang.String |
toString() |
byte |
type() |
byte |
version() |
deserialize, serializeKey, serializeValue
public static final byte ID
public TierTopicInitLeader(org.apache.kafka.common.TopicPartition topicPartition, int tierEpoch, java.util.UUID messageId, int brokerId)
public TierTopicInitLeader(org.apache.kafka.common.TopicPartition topicPartition, InitLeader init)
public byte type()
type
in class AbstractTierMetadata
public java.nio.ByteBuffer payloadBuffer()
payloadBuffer
in class AbstractTierMetadata
public org.apache.kafka.common.TopicPartition topicPartition()
AbstractTierMetadata
topicPartition
in class AbstractTierMetadata
public int tierEpoch()
AbstractTierMetadata
tierEpoch
in class AbstractTierMetadata
public byte version()
public java.util.UUID messageId()
public int brokerId()
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object