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, getTopicPartition, 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()