Package org.apache.kafka.server.policy

Interface CreateClusterLinkPolicy

All Superinterfaces:

Configurable

public interface CreateClusterLinkPolicy
extends Configurable

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DESTINATION
static final String	SOURCE

Method Summary

Modifier and Type	Method	Description
void	setTenantMaxDestLinks(Optional<String> tenantId, Optional<Integer> maxDestinationLinks)
void	setTenantMaxSourceLinks(Optional<String> tenantId, Optional<Integer> maxSourceLinks)
void	validate(Optional<String> tenantPrefix, String linkMode, Map<String,String> configs)

Methods inherited from interface org.apache.kafka.common.Configurable

configure

Field Details

DESTINATION

static final String DESTINATION

See Also:

• Constant Field Values

SOURCE

static final String SOURCE

See Also:

• Constant Field Values

Method Details

validate

void validate(Optional<String> tenantPrefix,
 String linkMode,
 Map<String,String> configs)
       throws PolicyViolationException

Throws:

PolicyViolationException

setTenantMaxSourceLinks

void setTenantMaxSourceLinks(Optional<String> tenantId,
 Optional<Integer> maxSourceLinks)

setTenantMaxDestLinks

void setTenantMaxDestLinks(Optional<String> tenantId,
 Optional<Integer> maxDestinationLinks)