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