Class AlterConfigPolicy.ClusterPolicyConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

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

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

Enclosing class:

AlterConfigPolicy

public static class AlterConfigPolicy.ClusterPolicyConfig
extends AbstractPolicyConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ALTER_ENABLE_CONFIG
static final String	CONFIG_PREFIX
static final long	DEFAULT_MAX_COMPACTION_LAG_MS_MIN
static final int	DEFAULT_NUM_PARTITIONS_MAX
static final int	DEFAULT_NUM_PARTITIONS_MIN
static final long	DEFAULT_RETENTION_MS_MAX
static final long	DEFAULT_RETENTION_MS_MIN
static final List<String>	DEFAULT_SSL_CIPHER_SUITES_ALLOWED
static final List<String>	DEFAULT_SSL_ENABLED_PROTOCOLS_ALLOWED
static final String	MAX_COMPACTION_LAG_MS_MIN_CONFIG
static final String	NUM_PARTITIONS_MAX_CONFIG
static final String	NUM_PARTITIONS_MIN_CONFIG
static final String	RETENTION_MS_MAX_CONFIG
static final String	RETENTION_MS_MIN_CONFIG
static final String	SSL_CIPHER_SUITES_ALLOWED_CONFIG
static final String	SSL_ENABLED_PROTOCOLS_ALLOWED_CONFIG

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Method Summary

Modifier and Type	Method	Description
static String	invalidCipherSuiteMessage(Collection<String> allowedCipherSuites, String cipherSuites)
static String	invalidEnabledProtocolsMessage(Collection<String> allowedProtocols, String protocols)
void	validateBrokerConfigs(org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata reqMetadata)

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 java.lang.Object

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

Field Details

CONFIG_PREFIX

public static final String CONFIG_PREFIX

See Also:

• Constant Field Values

ALTER_ENABLE_CONFIG

public static final String ALTER_ENABLE_CONFIG

See Also:

• Constant Field Values

SSL_CIPHER_SUITES_ALLOWED_CONFIG

public static final String SSL_CIPHER_SUITES_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_SSL_CIPHER_SUITES_ALLOWED

public static final List<String> DEFAULT_SSL_CIPHER_SUITES_ALLOWED

SSL_ENABLED_PROTOCOLS_ALLOWED_CONFIG

public static final String SSL_ENABLED_PROTOCOLS_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_SSL_ENABLED_PROTOCOLS_ALLOWED

public static final List<String> DEFAULT_SSL_ENABLED_PROTOCOLS_ALLOWED

NUM_PARTITIONS_MIN_CONFIG

public static final String NUM_PARTITIONS_MIN_CONFIG

See Also:

• Constant Field Values

DEFAULT_NUM_PARTITIONS_MIN

public static final int DEFAULT_NUM_PARTITIONS_MIN

See Also:

• Constant Field Values

NUM_PARTITIONS_MAX_CONFIG

public static final String NUM_PARTITIONS_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_NUM_PARTITIONS_MAX

public static final int DEFAULT_NUM_PARTITIONS_MAX

See Also:

• Constant Field Values

RETENTION_MS_MIN_CONFIG

public static final String RETENTION_MS_MIN_CONFIG

DEFAULT_RETENTION_MS_MIN

public static final long DEFAULT_RETENTION_MS_MIN

RETENTION_MS_MAX_CONFIG

public static final String RETENTION_MS_MAX_CONFIG

DEFAULT_RETENTION_MS_MAX

public static final long DEFAULT_RETENTION_MS_MAX

See Also:

• Constant Field Values

MAX_COMPACTION_LAG_MS_MIN_CONFIG

public static final String MAX_COMPACTION_LAG_MS_MIN_CONFIG

DEFAULT_MAX_COMPACTION_LAG_MS_MIN

public static final long DEFAULT_MAX_COMPACTION_LAG_MS_MIN

Method Details

validateBrokerConfigs

public void validateBrokerConfigs(org.apache.kafka.server.policy.AlterConfigPolicy.RequestMetadata reqMetadata)

invalidEnabledProtocolsMessage

public static String invalidEnabledProtocolsMessage(Collection<String> allowedProtocols,
 String protocols)

invalidCipherSuiteMessage

public static String invalidCipherSuiteMessage(Collection<String> allowedCipherSuites,
 String cipherSuites)