public class PartitionLogRangeValidator extends Object
CompletableFutureRetryer
as a function.Constructor and Description |
---|
PartitionLogRangeValidator(org.apache.http.impl.client.CloseableHttpClient httpClient,
String topic,
int partition,
int brokerId,
long logStartOffset,
long logEndOffset,
ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Integer> |
validateLogRange()
Send Kafka request to validate partition log range asynchronously.
|
public PartitionLogRangeValidator(org.apache.http.impl.client.CloseableHttpClient httpClient, String topic, int partition, int brokerId, long logStartOffset, long logEndOffset, ThreadPoolExecutor executor)
public CompletableFuture<Integer> validateLogRange()