Interface BrokerReplicaExclusionManager

public interface BrokerReplicaExclusionManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<AlterBrokerReplicaExclusion>>	createBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest)	Atomically creates BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.
CompletableFuture<List<AlterBrokerReplicaExclusion>>	deleteBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest)	Atomically deletes BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.
CompletableFuture<Optional<BrokerReplicaExclusion>>	getBrokerReplicaExclusions(String clusterId, int brokerId)	Returns a BrokerReplicaExclusion for the Kafka Cluster with the given clusterId and Broker with the given brokerId.
CompletableFuture<List<BrokerReplicaExclusion>>	listBrokerReplicaExclusions(String clusterId)	Returns a list of all Kafka BrokerReplicaExclusion for a Kafka Cluster with given clusterId.

Method Details

listBrokerReplicaExclusions

CompletableFuture<List<BrokerReplicaExclusion>> listBrokerReplicaExclusions(String clusterId)

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

getBrokerReplicaExclusions

CompletableFuture<Optional<BrokerReplicaExclusion>> getBrokerReplicaExclusions(String clusterId,
 int brokerId)

Returns a BrokerReplicaExclusion for the Kafka Cluster with the given clusterId and Broker with the given brokerId.

createBrokerReplicaExclusions

CompletableFuture<List<AlterBrokerReplicaExclusion>> createBrokerReplicaExclusions(String clusterId,
 BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest)

Atomically creates BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.

deleteBrokerReplicaExclusions

CompletableFuture<List<AlterBrokerReplicaExclusion>> deleteBrokerReplicaExclusions(String clusterId,
 BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest)

Atomically deletes BrokerReplicaExclusion for the Kafka Cluster with the given clusterId for the brokers specified with BrokerReplicaExclusionBatchRequest and returns AlterBrokerReplicaExclusion.