public class FtpsFetcher extends Object
CompletableFutureRetryer
as a function.Constructor and Description |
---|
FtpsFetcher(org.apache.http.impl.client.CloseableHttpClient httpClient,
KafkaFetchFtpsRequest request,
String ftpsDirPath,
ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<KafkaFetchFtpsResponse> |
fetchFtpsFile()
Send Kafka request to download ftps asynchronously.
|
static String |
getFtpsFileName(String ftpsDirPath,
String topic,
int partition,
org.apache.http.client.methods.CloseableHttpResponse response)
Returns the filename that should be used to store the FTPS file for the given topic/partition.
|
public FtpsFetcher(org.apache.http.impl.client.CloseableHttpClient httpClient, KafkaFetchFtpsRequest request, String ftpsDirPath, ThreadPoolExecutor executor)
public CompletableFuture<KafkaFetchFtpsResponse> fetchFtpsFile()
public static String getFtpsFileName(String ftpsDirPath, String topic, int partition, org.apache.http.client.methods.CloseableHttpResponse response)
topic
- topic associated with FTPS filepartition
- partition number associated with FTPS file