public class KafkaForceRestoreRequest extends KafkaRequest
Constructor and Description |
---|
KafkaForceRestoreRequest(int uuid,
String topic,
int partition,
NodeConfig broker,
long logStartOffset,
long logEndOffset,
String contentHash,
byte checksumAlgorithmId) |
Modifier and Type | Method and Description |
---|---|
byte |
getChecksumAlgorithmId() |
String |
getContentHash() |
long |
getLogEndOffset() |
long |
getLogStartOffset() |
getBroker, toString
getCreateTimestamp, getPartition, getTopic, getTopicPartition, getUuid, name
public KafkaForceRestoreRequest(int uuid, String topic, int partition, NodeConfig broker, long logStartOffset, long logEndOffset, String contentHash, byte checksumAlgorithmId)
public long getLogStartOffset()
public long getLogEndOffset()
public String getContentHash()
public byte getChecksumAlgorithmId()