public class CreateClusterLinkPolicy extends Object implements org.apache.kafka.server.policy.CreateClusterLinkPolicy, org.apache.kafka.server.interceptor.ClusterLinkInterceptor, org.apache.kafka.common.Reconfigurable
Constructor and Description |
---|
CreateClusterLinkPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
void |
linkAdded(UUID linkId,
Optional<String> tenantPrefix,
String linkModeStr) |
void |
linkDeleted(UUID linkId) |
Set<UUID> |
links() |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
void |
validate(Optional<String> tenantPrefix,
String linkModeStr,
Map<String,String> configs) |
void |
validateReconfiguration(Map<String,?> configs) |
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void reconfigure(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void validate(Optional<String> tenantPrefix, String linkModeStr, Map<String,String> configs) throws org.apache.kafka.common.errors.PolicyViolationException
validate
in interface org.apache.kafka.server.policy.CreateClusterLinkPolicy
org.apache.kafka.common.errors.PolicyViolationException
public void linkAdded(UUID linkId, Optional<String> tenantPrefix, String linkModeStr)
linkAdded
in interface org.apache.kafka.server.interceptor.ClusterLinkInterceptor
public void linkDeleted(UUID linkId)
linkDeleted
in interface org.apache.kafka.server.interceptor.ClusterLinkInterceptor