public class TopicPolicyConfig extends AbstractPolicyConfig
Constructor and Description |
---|
TopicPolicyConfig(java.util.Map<java.lang.String,?> clientConfigs) |
Modifier and Type | Method and Description |
---|---|
static void |
main(java.lang.String[] args) |
java.util.Map<java.lang.String,java.lang.String> |
restrictTopicConfigs(java.util.Map<java.lang.String,java.lang.String> configs) |
void |
validateTopicConfigs(java.util.Map<java.lang.String,java.lang.String> configs) |
checkPolicyMax, checkPolicyMin, parseList, parseLong
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String BASE_PREFIX
public static final java.lang.String TOPIC_PREFIX
public static final java.lang.String SEGMENT_BYTES_MIN_CONFIG
public static final int DEFAULT_SEGMENT_BYTES_MIN
protected static final java.lang.String SEGMENT_BYTES_MIN_CONFIG_DOC
public static final java.lang.String SEGMENT_BYTES_MAX_CONFIG
public static final int DEFAULT_SEGMENT_BYTES_MAX
protected static final java.lang.String SEGMENT_BYTES_MAX_CONFIG_DOC
public static final java.lang.String SEGMENT_MS_MIN_CONFIG
public static final int DEFAULT_SEGMENT_MS_MIN
protected static final java.lang.String SEGMENT_MS_MIN_CONFIG_DOC
public static final java.lang.String RETENTION_MS_MAX_CONFIG
public static final long DEFAULT_RETENTION_MS_MAX
protected static final java.lang.String RETENTION_MS_MAX_CONFIG_DOC
public static final java.lang.String DELETE_RETENTION_MS_MAX_CONFIG
public static final long DEFAULT_DELETE_RETENTION_MS_MAX
protected static final java.lang.String DELETE_RETENTION_MS_MAX_CONFIG_DOC
public static final java.lang.String MAX_MESSAGE_BYTES_MAX_CONFIG
public static final int DEFAULT_MAX_MESSAGE_BYTES_MAX
protected static final java.lang.String MAX_MESSAGE_BYTES_MAX_CONFIG_DOC
public static final java.lang.String REPLICATION_FACTOR_CONFIG
protected static final java.lang.String REPLICATION_FACTOR_DOC
public static final java.lang.String MAX_PARTITIONS_PER_TENANT_CONFIG
public static final int DEFAULT_MAX_PARTITIONS_PER_TENANT
protected static final java.lang.String MAX_PARTITIONS_PER_TENANT_CONFIG_DOC
public static final java.lang.String INTERNAL_LISTENER_CONFIG
public static final java.lang.String DEFAULT_INTERNAL_LISTENER
protected static final java.lang.String INTERNAL_LISTENER_CONFIG_DOC
public static final java.lang.String MAX_COMPACTION_LAG_MS_MIN_CONFIG
public static final long DEFAULT_MAX_COMPACTION_LAG_MS_MIN
public static final short MIN_ISR
public TopicPolicyConfig(java.util.Map<java.lang.String,?> clientConfigs)
public static void main(java.lang.String[] args)
public void validateTopicConfigs(java.util.Map<java.lang.String,java.lang.String> configs)
public java.util.Map<java.lang.String,java.lang.String> restrictTopicConfigs(java.util.Map<java.lang.String,java.lang.String> configs)