Class AlterConfigPolicy

java.lang.Object

io.confluent.kafka.server.plugins.policy.AlterConfigPolicy

All Implemented Interfaces:

CpcMetadataPublisher, AutoCloseable, kafka.server.link.ClusterLinkAlterConfigPolicy, org.apache.kafka.common.Configurable, org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher, org.apache.kafka.server.multitenant.TenantConfigSourceAware, org.apache.kafka.server.policy.AlterConfigPolicy

Direct Known Subclasses:

CpcAlterConfigPolicy

public class AlterConfigPolicy
extends Object
implements kafka.server.link.ClusterLinkAlterConfigPolicy, org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher, CpcMetadataPublisher, org.apache.kafka.server.multitenant.TenantConfigSourceAware

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AlterConfigPolicy.ClusterPolicyConfig
static class	AlterConfigPolicy.GroupPolicyConfig

Nested classes/interfaces inherited from interface org.apache.kafka.server.policy.AlterConfigPolicy

org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata

Constructor Summary

Constructors

Constructor	Description
AlterConfigPolicy()

Method Summary

Modifier and Type	Method	Description
void	close()
Map<String,String>	clusterLinkRestrictTopicConfigs(Map<String,String> configs)
void	clusterLinkValidateTopicConfigs(Map<String,String> configs)
void	configure(Map<String,?> configMap)
String	name()
void	onCpcMetadataUpdate(Map<String, io.confluent.kafka.cpc.multitenant.CpcLogicalClusterMetadata> cpcMetadataDelta)
void	onInitialLoadFailed(Throwable error)
void	onMetadataUpdate(Map<String, ? extends org.apache.kafka.server.multitenant.LogicalClusterMetadata> multiTenantMetadataDelta)
void	setTenantConfigSource(org.apache.kafka.server.multitenant.TenantConfigSource source)
void	validate(org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata reqMetadata)	We allow updates for a subset of configs in CCloud using the external listener where all principals are MultiTenantPrincipals.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AlterConfigPolicy

public AlterConfigPolicy()

Method Details

configure

public void configure(Map<String,?> configMap)

Specified by:

configure in interface org.apache.kafka.common.Configurable

setTenantConfigSource

public void setTenantConfigSource(org.apache.kafka.server.multitenant.TenantConfigSource source)

Specified by:

setTenantConfigSource in interface org.apache.kafka.server.multitenant.TenantConfigSourceAware

validate

public void validate(org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata reqMetadata)
              throws org.apache.kafka.common.errors.PolicyViolationException

We allow updates for a subset of configs in CCloud using the external listener where all principals are MultiTenantPrincipals. On internal listeners with regular non-tenant principals, config updates are permitted, for example to update SSL keystores without broker restart.

Specified by:

validate in interface org.apache.kafka.server.policy.AlterConfigPolicy

Throws:

org.apache.kafka.common.errors.PolicyViolationException

clusterLinkValidateTopicConfigs

public void clusterLinkValidateTopicConfigs(Map<String,String> configs)

Specified by:

clusterLinkValidateTopicConfigs in interface kafka.server.link.ClusterLinkAlterConfigPolicy

clusterLinkRestrictTopicConfigs

public Map<String,String> clusterLinkRestrictTopicConfigs(Map<String,String> configs)

Specified by:

clusterLinkRestrictTopicConfigs in interface kafka.server.link.ClusterLinkAlterConfigPolicy

close

public void close()

Specified by:

close in interface AutoCloseable

name

public String name()

Specified by:

name in interface org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher

onInitialLoadFailed

public void onInitialLoadFailed(Throwable error)

Specified by:

onInitialLoadFailed in interface org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher

onMetadataUpdate

public void onMetadataUpdate(Map<String, ? extends org.apache.kafka.server.multitenant.LogicalClusterMetadata> multiTenantMetadataDelta)

Specified by:

onMetadataUpdate in interface org.apache.kafka.server.multitenant.MultiTenantMetadataPublisher

onCpcMetadataUpdate

public void onCpcMetadataUpdate(Map<String, io.confluent.kafka.cpc.multitenant.CpcLogicalClusterMetadata> cpcMetadataDelta)

Specified by:

onCpcMetadataUpdate in interface CpcMetadataPublisher