Class TopicPolicyConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig

io.confluent.kafka.server.plugins.policy.TopicPolicyConfig

public class TopicPolicyConfig
extends AbstractPolicyConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BASE_PREFIX
static final String	CLEANUP_POLICY_ALLOWED_CONFIG
static final String	DEFAULT_CLEANUP_POLICIES_ALLOWED
static final long	DEFAULT_DELETE_RETENTION_MS_MAX
static final String	DEFAULT_INTERNAL_LISTENER
static final long	DEFAULT_MAX_COMPACTION_LAG_MS_MIN
static final int	DEFAULT_MAX_MESSAGE_BYTES_MAX
static final int	DEFAULT_MAX_PARTITIONS_PER_CLUSTER
static final int	DEFAULT_MAX_PARTITIONS_PER_TENANT
static final int	DEFAULT_MAX_REPLICAS_PER_BROKER
static final int	DEFAULT_MAX_TOPICS_PER_CLUSTER
static final short	DEFAULT_REPLICATION_FACTOR
static final long	DEFAULT_RETENTION_MS_MAX
static final int	DEFAULT_SEGMENT_BYTES_MAX
static final int	DEFAULT_SEGMENT_BYTES_MIN
static final int	DEFAULT_SEGMENT_MS_MIN
static final String	DELETE_RETENTION_MS_MAX_CONFIG
static final String	INTERNAL_LISTENER_CONFIG
static final String	MAX_COMPACTION_LAG_MS_MIN_CONFIG
static final String	MAX_MESSAGE_BYTES_MAX_CONFIG
static final String	MAX_PARTITIONS_PER_CLUSTER_CONFIG
static final String	MAX_PARTITIONS_PER_TENANT_CONFIG
static final String	MAX_REPLICAS_PER_BROKER_CONFIG
static final String	MAX_TOPICS_PER_CLUSTER_CONFIG
static final short	MIN_ISR
static final String	MULTITENANT_MAX_PARTITIONS_PER_REQUEST_CONFIG
static final int	MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DEFAULT
static final String	MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DOC
static final String	MULTITENANT_SCHEMA_VALIDATION_ENABLED_CONFIG
static final boolean	MULTITENANT_SCHEMA_VALIDATION_ENABLED_DEFAULT
static final String	REPLICATION_FACTOR_CONFIG
static final String	RETENTION_MS_MAX_CONFIG
static final String	SEGMENT_BYTES_MAX_CONFIG
static final String	SEGMENT_BYTES_MIN_CONFIG
static final String	SEGMENT_MS_MIN_CONFIG
static final String	TOPIC_PREFIX

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
TopicPolicyConfig(Map<String,?> clientConfigs)

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)
Map<String,String>	restrictClusterLinkTopicConfigs(Map<String,String> configs)
void	validateClusterLinkTopicConfigs(Map<String,String> configs)
void	validateTopicConfigs(Map<String,String> configs, org.apache.kafka.common.TopicType topicType, Integer tenantMaxMessageSizeBytes)

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

BASE_PREFIX

public static final String BASE_PREFIX

See Also:

• Constant Field Values

TOPIC_PREFIX

public static final String TOPIC_PREFIX

See Also:

• Constant Field Values

SEGMENT_BYTES_MIN_CONFIG

public static final String SEGMENT_BYTES_MIN_CONFIG

See Also:

• Constant Field Values

DEFAULT_SEGMENT_BYTES_MIN

public static final int DEFAULT_SEGMENT_BYTES_MIN

See Also:

• Constant Field Values

SEGMENT_BYTES_MAX_CONFIG

public static final String SEGMENT_BYTES_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_SEGMENT_BYTES_MAX

public static final int DEFAULT_SEGMENT_BYTES_MAX

See Also:

• Constant Field Values

SEGMENT_MS_MIN_CONFIG

public static final String SEGMENT_MS_MIN_CONFIG

See Also:

• Constant Field Values

DEFAULT_SEGMENT_MS_MIN

public static final int DEFAULT_SEGMENT_MS_MIN

See Also:

• Constant Field Values

RETENTION_MS_MAX_CONFIG

public static final String RETENTION_MS_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_RETENTION_MS_MAX

public static final long DEFAULT_RETENTION_MS_MAX

See Also:

• Constant Field Values

DELETE_RETENTION_MS_MAX_CONFIG

public static final String DELETE_RETENTION_MS_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_DELETE_RETENTION_MS_MAX

public static final long DEFAULT_DELETE_RETENTION_MS_MAX

See Also:

• Constant Field Values

CLEANUP_POLICY_ALLOWED_CONFIG

public static final String CLEANUP_POLICY_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_CLEANUP_POLICIES_ALLOWED

public static final String DEFAULT_CLEANUP_POLICIES_ALLOWED

MAX_MESSAGE_BYTES_MAX_CONFIG

public static final String MAX_MESSAGE_BYTES_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_MESSAGE_BYTES_MAX

public static final int DEFAULT_MAX_MESSAGE_BYTES_MAX

See Also:

• Constant Field Values

REPLICATION_FACTOR_CONFIG

public static final String REPLICATION_FACTOR_CONFIG

See Also:

• Constant Field Values

DEFAULT_REPLICATION_FACTOR

public static final short DEFAULT_REPLICATION_FACTOR

See Also:

• Constant Field Values

MAX_REPLICAS_PER_BROKER_CONFIG

public static final String MAX_REPLICAS_PER_BROKER_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_REPLICAS_PER_BROKER

public static final int DEFAULT_MAX_REPLICAS_PER_BROKER

See Also:

• Constant Field Values

MAX_PARTITIONS_PER_TENANT_CONFIG

public static final String MAX_PARTITIONS_PER_TENANT_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_PARTITIONS_PER_TENANT

public static final int DEFAULT_MAX_PARTITIONS_PER_TENANT

See Also:

• Constant Field Values

MAX_PARTITIONS_PER_CLUSTER_CONFIG

public static final String MAX_PARTITIONS_PER_CLUSTER_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_PARTITIONS_PER_CLUSTER

public static final int DEFAULT_MAX_PARTITIONS_PER_CLUSTER

See Also:

• Constant Field Values

MAX_TOPICS_PER_CLUSTER_CONFIG

public static final String MAX_TOPICS_PER_CLUSTER_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_TOPICS_PER_CLUSTER

public static final int DEFAULT_MAX_TOPICS_PER_CLUSTER

See Also:

• Constant Field Values

INTERNAL_LISTENER_CONFIG

public static final String INTERNAL_LISTENER_CONFIG

See Also:

• Constant Field Values

DEFAULT_INTERNAL_LISTENER

public static final String DEFAULT_INTERNAL_LISTENER

See Also:

• Constant Field Values

MAX_COMPACTION_LAG_MS_MIN_CONFIG

public static final String MAX_COMPACTION_LAG_MS_MIN_CONFIG

See Also:

• Constant Field Values

DEFAULT_MAX_COMPACTION_LAG_MS_MIN

public static final long DEFAULT_MAX_COMPACTION_LAG_MS_MIN

MULTITENANT_SCHEMA_VALIDATION_ENABLED_CONFIG

public static final String MULTITENANT_SCHEMA_VALIDATION_ENABLED_CONFIG

See Also:

• Constant Field Values

MULTITENANT_SCHEMA_VALIDATION_ENABLED_DEFAULT

public static final boolean MULTITENANT_SCHEMA_VALIDATION_ENABLED_DEFAULT

See Also:

• Constant Field Values

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_CONFIG

public static final String MULTITENANT_MAX_PARTITIONS_PER_REQUEST_CONFIG

See Also:

• Constant Field Values

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DOC

public static final String MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DOC

See Also:

• Constant Field Values

MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DEFAULT

public static final int MULTITENANT_MAX_PARTITIONS_PER_REQUEST_DEFAULT

See Also:

• Constant Field Values

MIN_ISR

public static final short MIN_ISR

See Also:

• Constant Field Values

Constructor Details

TopicPolicyConfig

public TopicPolicyConfig(Map<String,?> clientConfigs)

Method Details

main

public static void main(String[] args)

validateClusterLinkTopicConfigs

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

validateTopicConfigs

public void validateTopicConfigs(Map<String,String> configs,
 org.apache.kafka.common.TopicType topicType,
 Integer tenantMaxMessageSizeBytes)

restrictClusterLinkTopicConfigs

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