public class CreateClusterLinkPolicy extends Object implements kafka.server.link.CreateClusterLinkPolicy, org.apache.kafka.common.Reconfigurable, org.apache.kafka.server.interceptor.ClusterLinkInterceptor
Modifier and Type | Field and Description |
---|---|
static String |
DESTINATION |
static String |
SOURCE |
Constructor and Description |
---|
CreateClusterLinkPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
void |
linkAdded(UUID linkId,
Optional<String> tenantPrefix,
String linkMode) |
void |
linkDeleted(UUID linkId) |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
void |
validate(Optional<String> tenantPrefix,
String linkMode) |
void |
validateReconfiguration(Map<String,?> configs) |
public static final String DESTINATION
public static final String SOURCE
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 linkMode) throws org.apache.kafka.common.errors.PolicyViolationException
validate
in interface kafka.server.link.CreateClusterLinkPolicy
org.apache.kafka.common.errors.PolicyViolationException
public void linkAdded(UUID linkId, Optional<String> tenantPrefix, String linkMode)
linkAdded
in interface org.apache.kafka.server.interceptor.ClusterLinkInterceptor
public void linkDeleted(UUID linkId)
linkDeleted
in interface org.apache.kafka.server.interceptor.ClusterLinkInterceptor