public class PartitionStatusFetcher extends Object
CompletableFutureRetryer
as a function.Constructor and Description |
---|
PartitionStatusFetcher(org.apache.http.impl.client.CloseableHttpClient httpClient,
String topic,
int partition,
int brokerId,
int expectedStatus,
ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Integer> |
fetchPartitionStatus()
Send Kafka request to fetch Partition Status asynchronously.
|
public PartitionStatusFetcher(org.apache.http.impl.client.CloseableHttpClient httpClient, String topic, int partition, int brokerId, int expectedStatus, ThreadPoolExecutor executor)
public CompletableFuture<Integer> fetchPartitionStatus()