Interface BrokerTaskManager
public interface BrokerTaskManager
-
Method Summary
Modifier and TypeMethodDescriptiongetBrokerTask(String clusterId, int brokerId, BrokerTaskType taskType) Returns aBrokerTaskfor the KafkaClusterwith the givenclusterId,Brokerwith the givenbrokerIdandBrokerTaskTypewith the giventaskType.listBrokerTasks(String clusterId) listBrokerTasksByBroker(String clusterId, int brokerId) Returns a list ofBrokerTaskfor the KafkaClusterwith the givenclusterIdandBrokerwith the givenbrokerIdlistBrokerTasksByTaskType(String clusterId, BrokerTaskType taskType) Returns a list of KafkaBrokerTaskofBrokerTaskTypewith giventaskTypefor a KafkaClusterwith givenclusterId.
-
Method Details
-
listBrokerTasks
-
listBrokerTasksByTaskType
CompletableFuture<List<BrokerTask>> listBrokerTasksByTaskType(String clusterId, BrokerTaskType taskType) Returns a list of KafkaBrokerTaskofBrokerTaskTypewith giventaskTypefor a KafkaClusterwith givenclusterId. -
listBrokerTasksByBroker
Returns a list ofBrokerTaskfor the KafkaClusterwith the givenclusterIdandBrokerwith the givenbrokerId -
getBrokerTask
CompletableFuture<Optional<BrokerTask>> getBrokerTask(String clusterId, int brokerId, BrokerTaskType taskType) Returns aBrokerTaskfor the KafkaClusterwith the givenclusterId,Brokerwith the givenbrokerIdandBrokerTaskTypewith the giventaskType.
-