Class CpcAlterConfigPolicy

java.lang.Object

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

io.confluent.kafka.server.plugins.policy.CpcAlterConfigPolicy

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

public class CpcAlterConfigPolicy
extends AlterConfigPolicy

CPC-specific alter-config policy.

Extension point for CPC clusters whose config-alteration validation needs to diverge from the Confluent Cloud behavior implemented by AlterConfigPolicy. It currently inherits all base behavior unchanged; CPC-specific differences are added here as overrides so the Cloud policy stays free of CPC conditionals.

Activated by pointing alter.config.policy.class.name at this class on CPC clusters; the broker loads it via config.getConfiguredInstance(...).

Nested Class Summary

Nested classes/interfaces inherited from class AlterConfigPolicy

AlterConfigPolicy.ClusterPolicyConfig, 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
CpcAlterConfigPolicy()

Method Summary

Methods inherited from class AlterConfigPolicy

close, clusterLinkRestrictTopicConfigs, clusterLinkValidateTopicConfigs, configure, name, onCpcMetadataUpdate, onInitialLoadFailed, onMetadataUpdate, setTenantConfigSource, validate

Methods inherited from class Object

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

Constructor Details

CpcAlterConfigPolicy

public CpcAlterConfigPolicy()