Interface BrokerReplicaExclusionManager
public interface BrokerReplicaExclusionManager
-
Method Summary
Modifier and TypeMethodDescriptioncreateBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest) Atomically createsBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdfor the brokers specified withBrokerReplicaExclusionBatchRequestand returnsAlterBrokerReplicaExclusion.deleteBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest) Atomically deletesBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdfor the brokers specified withBrokerReplicaExclusionBatchRequestand returnsAlterBrokerReplicaExclusion.getBrokerReplicaExclusions(String clusterId, int brokerId) Returns aBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdandBrokerwith the givenbrokerId.listBrokerReplicaExclusions(String clusterId)
-
Method Details
-
listBrokerReplicaExclusions
-
getBrokerReplicaExclusions
CompletableFuture<Optional<BrokerReplicaExclusion>> getBrokerReplicaExclusions(String clusterId, int brokerId) Returns aBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdandBrokerwith the givenbrokerId. -
createBrokerReplicaExclusions
CompletableFuture<List<AlterBrokerReplicaExclusion>> createBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest) Atomically createsBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdfor the brokers specified withBrokerReplicaExclusionBatchRequestand returnsAlterBrokerReplicaExclusion. -
deleteBrokerReplicaExclusions
CompletableFuture<List<AlterBrokerReplicaExclusion>> deleteBrokerReplicaExclusions(String clusterId, BrokerReplicaExclusionBatchRequest createBrokerReplicaExclusionsBatchRequest) Atomically deletesBrokerReplicaExclusionfor the KafkaClusterwith the givenclusterIdfor the brokers specified withBrokerReplicaExclusionBatchRequestand returnsAlterBrokerReplicaExclusion.
-