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