Interface BrokerTaskManager

public interface BrokerTaskManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Optional<BrokerTask>>	getBrokerTask(String clusterId, int brokerId, BrokerTaskType taskType)	Returns a BrokerTask for the Kafka Cluster with the given clusterId, Broker with the given brokerId and BrokerTaskType with the given taskType.
CompletableFuture<List<BrokerTask>>	listBrokerTasks(String clusterId)	Returns a list of all Kafka BrokerTask for a Kafka Cluster with given clusterId.
CompletableFuture<List<BrokerTask>>	listBrokerTasksByBroker(String clusterId, int brokerId)	Returns a list of BrokerTask for the Kafka Cluster with the given clusterId and Broker with the given brokerId
CompletableFuture<List<BrokerTask>>	listBrokerTasksByTaskType(String clusterId, BrokerTaskType taskType)	Returns a list of Kafka BrokerTask of BrokerTaskType with given taskType for a Kafka Cluster with given clusterId.

Method Details

listBrokerTasks

CompletableFuture<List<BrokerTask>> listBrokerTasks(String clusterId)

Returns a list of all Kafka BrokerTask for a Kafka Cluster with given clusterId.

listBrokerTasksByTaskType

CompletableFuture<List<BrokerTask>> listBrokerTasksByTaskType(String clusterId,
 BrokerTaskType taskType)

Returns a list of Kafka BrokerTask of BrokerTaskType with given taskType for a Kafka Cluster with given clusterId.

listBrokerTasksByBroker

CompletableFuture<List<BrokerTask>> listBrokerTasksByBroker(String clusterId,
 int brokerId)

Returns a list of BrokerTask for the Kafka Cluster with the given clusterId and Broker with the given brokerId

getBrokerTask

CompletableFuture<Optional<BrokerTask>> getBrokerTask(String clusterId,
 int brokerId,
 BrokerTaskType taskType)

Returns a BrokerTask for the Kafka Cluster with the given clusterId, Broker with the given brokerId and BrokerTaskType with the given taskType.