public class KafkaValidateLogRangeRequest extends KafkaRequest
broker
Constructor and Description |
---|
KafkaValidateLogRangeRequest(int uuid,
String topic,
int partition,
NodeConfig broker,
List<NodeConfig> replicaBrokers,
long logStartOffset,
long logEndOffset) |
Modifier and Type | Method and Description |
---|---|
long |
getLogEndOffset() |
long |
getLogStartOffset() |
List<NodeConfig> |
getReplicaBrokers() |
getBroker, toString
getCreateTimestamp, getPartition, getTopic, getUuid, name
public KafkaValidateLogRangeRequest(int uuid, String topic, int partition, NodeConfig broker, List<NodeConfig> replicaBrokers, long logStartOffset, long logEndOffset)
public long getLogStartOffset()
public long getLogEndOffset()
public List<NodeConfig> getReplicaBrokers()