public class BrokerReplicaExclusionUtils extends Object
Constructor and Description |
---|
BrokerReplicaExclusionUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
exclusionExists(Map<Integer,String> existingExclusions,
int givenBrokerId)
Given a map of existing broker replica exclusions, determine whether the given broker replica exclusion exists in the map.
|
static boolean |
exclusionExists(Map<Integer,String> existingExclusions,
int givenBrokerId,
String givenReason)
Given a map of existing broker replica exclusions, determine whether the given broker replica exclusion exists in the map.
|
static boolean |
exclusionsMatchCurrentState(Map<Integer,String> currentBrokerReplicaExclusions,
Set<AlterReplicaExclusionOp> requestedExclusions)
Return a boolean indicating whether the user-requested
AlterReplicaExclusionOp
operations match the currently-active replica exclusions (e.g as in the case of duplicate requests) |
static BrokerReplicaExclusionModificationResult |
prepareReplicaExclusions(Map<Integer,String> exclusionsToModify,
Set<AlterReplicaExclusionOp> requestedExclusions)
Processes, validates and conditionally applies the requested replica exclusions to the current active set of replica exclusions.
|
public static BrokerReplicaExclusionModificationResult prepareReplicaExclusions(Map<Integer,String> exclusionsToModify, Set<AlterReplicaExclusionOp> requestedExclusions)
exclusionsToModify
- - the current set of active broker replica exclusions in the cluster.
This data structure gets modified according to the requested exclusionsrequestedExclusions
- - the set of requested replica exclusion operations AlterReplicaExclusionOp
to be appliedBrokerReplicaExclusionModificationResult
denoting the latest state of active replica exclusions in the clusterpublic static boolean exclusionExists(Map<Integer,String> existingExclusions, int givenBrokerId, String givenReason)
public static boolean exclusionExists(Map<Integer,String> existingExclusions, int givenBrokerId)
public static boolean exclusionsMatchCurrentState(Map<Integer,String> currentBrokerReplicaExclusions, Set<AlterReplicaExclusionOp> requestedExclusions)
AlterReplicaExclusionOp
operations match the currently-active replica exclusions (e.g as in the case of duplicate requests)currentBrokerReplicaExclusions
- the currently-active broker replica exclusions (key: broker id, value: a string denoting the reason for exclusion)requestedExclusions
- a set of user-requested exclusion operations