public class DryrunKafkaConnectionPoolImpl extends KafkaConnectionPoolImpl
Constructor and Description |
---|
DryrunKafkaConnectionPoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver,
int poolSize,
String ftpsDirPath,
RestoreMetricsManager metricsManager,
org.apache.kafka.common.utils.Time time)
Constructs new KafkaConnectionPool with given resultsReceiver.
|
Modifier and Type | Method and Description |
---|---|
protected void |
submitFetchFtpsRequest(KafkaFetchFtpsRequest request) |
protected void |
submitKafkaEventRequest(KafkaRequest request) |
protected void |
submitKafkaValidateLogRangeRequest(KafkaValidateLogRangeRequest request) |
protected void |
submitTierPartitionStatusRequest(KafkaTierPartitionStatusRequest request)
Submits a KafkaTierPartitionStatusRequest to be scheduled.
|
reportFetchFtpsResponse, reportFetchFtpsResponse, reportKafkaResponse, reportKafkaValidateLogRangeResponse, reportTierPartitionStatusResponse, setHttpClient, setStatusQueryRetryWaitInMs, shutdown, startUp, submitKafkaRequest
public DryrunKafkaConnectionPoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver, int poolSize, String ftpsDirPath, RestoreMetricsManager metricsManager, 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 storedprotected void submitKafkaEventRequest(KafkaRequest request)
submitKafkaEventRequest
in class KafkaConnectionPoolImpl
protected void submitFetchFtpsRequest(KafkaFetchFtpsRequest request)
submitFetchFtpsRequest
in class KafkaConnectionPoolImpl
protected void submitTierPartitionStatusRequest(KafkaTierPartitionStatusRequest request)
KafkaConnectionPoolImpl
submitTierPartitionStatusRequest
in class KafkaConnectionPoolImpl
protected void submitKafkaValidateLogRangeRequest(KafkaValidateLogRangeRequest request)
submitKafkaValidateLogRangeRequest
in class KafkaConnectionPoolImpl