public class KafkaValidateLogRangeRequest extends KafkaRequest
brokerID
Constructor and Description |
---|
KafkaValidateLogRangeRequest(int uuid,
String topic,
int partition,
int brokerID,
List<Integer> replicaBrokerIDs,
long logStartOffset,
long logEndOffset) |
Modifier and Type | Method and Description |
---|---|
long |
getLogEndOffset() |
long |
getLogStartOffset() |
List<Integer> |
getReplicaBrokerIDs() |
getBrokerID, toString
getCreateTimestamp, getPartition, getTopic, getUuid, name