public class KafkaManager extends AbstractAsyncServiceScheduler
AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus
Constructor and Description |
---|
KafkaManager(AsyncServiceSchedulerResultsReceiver resultsReceiver,
KafkaConnectionPool kafkaConnectionPool)
Constructs new KafkaManager with default request queue capacity.
|
KafkaManager(AsyncServiceSchedulerResultsReceiver resultsReceiver,
KafkaConnectionPool kafkaConnectionPool,
int requestQueueSize)
Constructs new KafkaManager.
|
Modifier and Type | Method and Description |
---|---|
boolean |
pause()
Pauses KafkaManager.
|
boolean |
resume()
Resumes KafkaManager.
|
boolean |
shutdown()
Shuts down the KafkaManager, cleaning up resources.
|
boolean |
startUp()
Starts up the KafkaManager, so it is ready to consume and process requests.
|
MessageStatusCode |
submitRequest(MessageRequest request)
Submits a
KafkaRequest to KafkaManager. |
getStatus
public KafkaManager(AsyncServiceSchedulerResultsReceiver resultsReceiver, KafkaConnectionPool kafkaConnectionPool, int requestQueueSize)
resultsReceiver
- subscriber to send responses to viakafkaConnectionPool
- pool for processing Kafka requestsrequestQueueSize
- maximum capacity of KafkaManager's request queue
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public KafkaManager(AsyncServiceSchedulerResultsReceiver resultsReceiver, KafkaConnectionPool kafkaConnectionPool)
resultsReceiver
- subscriber to send responses to viakafkaConnectionPool
- pool for processing Kafka requests
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public MessageStatusCode submitRequest(MessageRequest request)
KafkaRequest
to KafkaManager. Schedules request to be executed asynchronously.
Request must be FetchFtpsRequest, KafkaTierPartitionEventRequest, or KafkaTierPartitionStatusRequest.submitRequest
in class AbstractAsyncServiceScheduler
request
- request to be scheduledMessageStatusCode.SCHEDULED
on success;
MessageStatusCode.REQUEST_QUEUE_FULL
if request queue was full; or
MessageStatusCode.ILLEGAL_STATE_ERROR
if manager is not RUNNINGUnsupportedOperationException
- if request is of an invalid type.public boolean pause()
pause
in class AbstractAsyncServiceScheduler
public boolean resume()
resume
in class AbstractAsyncServiceScheduler
public boolean startUp()
startUp
in class AbstractAsyncServiceScheduler
public boolean shutdown()
shutdown
in class AbstractAsyncServiceScheduler