public class TopicPolicyConfig
extends org.apache.kafka.common.config.AbstractConfig
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 java.lang.String |
MIN_IN_SYNC_REPLICAS_CONFIG |
protected static java.lang.String |
MIN_IN_SYNC_REPLICAS_CONFIG_DOC |
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) |
TopicPolicyConfig(java.util.Properties props) |
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) |
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 MIN_IN_SYNC_REPLICAS_CONFIG
protected static final java.lang.String MIN_IN_SYNC_REPLICAS_CONFIG_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