public class KafkaConnectionPoolImpl extends Object implements KafkaConnectionPool
Constructor and Description |
---|
KafkaConnectionPoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver,
int poolSize,
String ftpsDirPath,
RestoreMetricsManager metrics,
org.apache.kafka.common.utils.Time time)
Constructs new KafkaConnectionPool with given resultsReceiver.
|
Modifier and Type | Method and Description |
---|---|
void |
setHttpClient(org.apache.http.impl.client.CloseableHttpClient httpClient)
For test.
|
void |
setStatusQueryRetryWaitInMs(long statusQueryRetryWaitInMs) |
void |
shutdown()
Shuts down KafkaConnectionPool resources.
|
void |
startUp()
Provisions necessary resources for running KafkaConnectionPool.
|
void |
submitKafkaRequest(KafkaRequest kafkaRequest)
Submits KafkaRequest to be scheduled.
|
public KafkaConnectionPoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver, int poolSize, String ftpsDirPath, RestoreMetricsManager metrics, org.apache.kafka.common.utils.Time time)
resultsReceiver
- results receiver to forward responses topoolSize
- maximum number of threads/concurrent connections in the KafkaConnectionPoolftpsDirPath
- directory in which fetched FTPS files should be storedpublic void setStatusQueryRetryWaitInMs(long statusQueryRetryWaitInMs)
public void setHttpClient(org.apache.http.impl.client.CloseableHttpClient httpClient)
public void startUp()
startUp
in interface KafkaConnectionPool
public void shutdown()
shutdown
in interface KafkaConnectionPool
public void submitKafkaRequest(KafkaRequest kafkaRequest)
submitKafkaRequest
in interface KafkaConnectionPool
kafkaRequest
- request to schedule.