Class ClusterLinkPolicyConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

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

io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig

public class ClusterLinkPolicyConfig
extends AbstractPolicyConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACL_SYNC_MS_MAX_CONFIG
static final String	ACL_SYNC_MS_MIN_CONFIG
static final String	AVAILABILITY_CHECK_MS_MAX_CONFIG
static final String	AVAILABILITY_CHECK_MS_MAX_DOC
static final String	AVAILABILITY_CHECK_MS_MIN_CONFIG
static final String	AVAILABILITY_CHECK_MS_MIN_DOC
static final String	BASE_PREFIX
static final String	CLUSTER_LINK_PREFIX
static final String	CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG
static final String	CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG
static final int	DEFAULT_ACL_SYNC_MS_MAX
static final int	DEFAULT_ACL_SYNC_MS_MIN
static final int	DEFAULT_AVAILABILITY_CHECK_MS_MAX
static final int	DEFAULT_AVAILABILITY_CHECK_MS_MIN
static final int	DEFAULT_CONSUMER_OFFSET_SYNC_MS_MAX
static final int	DEFAULT_CONSUMER_OFFSET_SYNC_MS_MIN
static final int	DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX
static final int	DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN
static final List<String>	DEFAULT_SASL_LOGIN_CALLBACK_HANDLER_ALLOWED
static final List<String>	DEFAULT_SASL_LOGIN_MODULES_ALLOWED
static final List<String>	DEFAULT_SASL_MECHANISMS_ALLOWED
static final int	DEFAULT_TOPIC_CONFIG_SYNC_MS_MAX
static final int	DEFAULT_TOPIC_CONFIG_SYNC_MS_MIN
static final String	DOC_MAX_PREFIX
static final String	DOC_MIN_PREFIX
static final String	DOC_SUFFIX
static final String	MAX_DEST_LINKS_PER_TENANT_CONFIG
static final String	MAX_SOURCE_LINKS_PER_TENANT_CONFIG
static final String	REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG
static final String	REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_CONFIG
static final String	SASL_LOGIN_CALLBACK_HANDLER_ALLOWED_CONFIG
static final String	SASL_LOGIN_MODULES_ALLOWED_CONFIG
static final String	SASL_MECHANISMS_ALLOWED_CONFIG
static final String	TOPIC_CONFIG_SYNC_MS_MAX_CONFIG
static final String	TOPIC_CONFIG_SYNC_MS_MIN_CONFIG

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
ClusterLinkPolicyConfig(Map<String,?> clientConfigs)

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)
void	validateClusterLinkConfigs(Map<String,String> configs)

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

BASE_PREFIX

public static final String BASE_PREFIX

See Also:

• Constant Field Values

CLUSTER_LINK_PREFIX

public static final String CLUSTER_LINK_PREFIX

See Also:

• Constant Field Values

DOC_MIN_PREFIX

public static final String DOC_MIN_PREFIX

See Also:

• Constant Field Values

DOC_MAX_PREFIX

public static final String DOC_MAX_PREFIX

See Also:

• Constant Field Values

DOC_SUFFIX

public static final String DOC_SUFFIX

See Also:

• Constant Field Values

ACL_SYNC_MS_MIN_CONFIG

public static final String ACL_SYNC_MS_MIN_CONFIG

DEFAULT_ACL_SYNC_MS_MIN

public static final int DEFAULT_ACL_SYNC_MS_MIN

See Also:

• Constant Field Values

ACL_SYNC_MS_MAX_CONFIG

public static final String ACL_SYNC_MS_MAX_CONFIG

DEFAULT_ACL_SYNC_MS_MAX

public static final int DEFAULT_ACL_SYNC_MS_MAX

See Also:

• Constant Field Values

CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG

public static final String CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG

DEFAULT_CONSUMER_OFFSET_SYNC_MS_MIN

public static final int DEFAULT_CONSUMER_OFFSET_SYNC_MS_MIN

See Also:

• Constant Field Values

CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG

public static final String CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG

DEFAULT_CONSUMER_OFFSET_SYNC_MS_MAX

public static final int DEFAULT_CONSUMER_OFFSET_SYNC_MS_MAX

See Also:

• Constant Field Values

TOPIC_CONFIG_SYNC_MS_MIN_CONFIG

public static final String TOPIC_CONFIG_SYNC_MS_MIN_CONFIG

DEFAULT_TOPIC_CONFIG_SYNC_MS_MIN

public static final int DEFAULT_TOPIC_CONFIG_SYNC_MS_MIN

See Also:

• Constant Field Values

TOPIC_CONFIG_SYNC_MS_MAX_CONFIG

public static final String TOPIC_CONFIG_SYNC_MS_MAX_CONFIG

DEFAULT_TOPIC_CONFIG_SYNC_MS_MAX

public static final int DEFAULT_TOPIC_CONFIG_SYNC_MS_MAX

See Also:

• Constant Field Values

SASL_MECHANISMS_ALLOWED_CONFIG

public static final String SASL_MECHANISMS_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_SASL_MECHANISMS_ALLOWED

public static final List<String> DEFAULT_SASL_MECHANISMS_ALLOWED

SASL_LOGIN_MODULES_ALLOWED_CONFIG

public static final String SASL_LOGIN_MODULES_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_SASL_LOGIN_MODULES_ALLOWED

public static final List<String> DEFAULT_SASL_LOGIN_MODULES_ALLOWED

SASL_LOGIN_CALLBACK_HANDLER_ALLOWED_CONFIG

public static final String SASL_LOGIN_CALLBACK_HANDLER_ALLOWED_CONFIG

See Also:

• Constant Field Values

DEFAULT_SASL_LOGIN_CALLBACK_HANDLER_ALLOWED

public static final List<String> DEFAULT_SASL_LOGIN_CALLBACK_HANDLER_ALLOWED

REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_CONFIG

public static final String REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_CONFIG

See Also:

• Constant Field Values

DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN

public static final int DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN

See Also:

• Constant Field Values

REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG

public static final String REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG

See Also:

• Constant Field Values

DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX

public static final int DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX

See Also:

• Constant Field Values

AVAILABILITY_CHECK_MS_MIN_CONFIG

public static final String AVAILABILITY_CHECK_MS_MIN_CONFIG

DEFAULT_AVAILABILITY_CHECK_MS_MIN

public static final int DEFAULT_AVAILABILITY_CHECK_MS_MIN

See Also:

• Constant Field Values

AVAILABILITY_CHECK_MS_MIN_DOC

public static final String AVAILABILITY_CHECK_MS_MIN_DOC

AVAILABILITY_CHECK_MS_MAX_CONFIG

public static final String AVAILABILITY_CHECK_MS_MAX_CONFIG

DEFAULT_AVAILABILITY_CHECK_MS_MAX

public static final int DEFAULT_AVAILABILITY_CHECK_MS_MAX

See Also:

• Constant Field Values

AVAILABILITY_CHECK_MS_MAX_DOC

public static final String AVAILABILITY_CHECK_MS_MAX_DOC

MAX_DEST_LINKS_PER_TENANT_CONFIG

public static final String MAX_DEST_LINKS_PER_TENANT_CONFIG

See Also:

• Constant Field Values

MAX_SOURCE_LINKS_PER_TENANT_CONFIG

public static final String MAX_SOURCE_LINKS_PER_TENANT_CONFIG

See Also:

• Constant Field Values

Constructor Details

ClusterLinkPolicyConfig

public ClusterLinkPolicyConfig(Map<String,?> clientConfigs)

Method Details

main

public static void main(String[] args)

validateClusterLinkConfigs

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