public class ReplicaExclusionCache extends Object
ReplicaExclusionCache
is a thread-safe cache containing the latest information about active broker replica exclusions in the cluster.
For more information about exclusion, see ConfluentAdmin.alterBrokerReplicaExclusions(Map)
.
This cache is only populated on the active controller.Constructor and Description |
---|
ReplicaExclusionCache() |
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
excludedBrokers()
Returns a set of the broker IDs that are excluded for replica placement.
|
Map<Integer,String> |
exclusions()
Returns a shallow-copy of a map containing the current broker replica exclusions.
|
void |
overrideMap(Map<Integer,String> newMap) |