public class AuditLogConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
AuditLogConfig(java.util.Map<java.lang.String,?> configs) |
Modifier and Type | Method and Description |
---|---|
static java.util.Properties |
kafkaInterBrokerClientConfig(java.util.Map<java.lang.String,?> originals) |
static java.util.Properties |
kafkaProducerOverrides() |
AuditLogRouterJsonConfig |
routerJsonConfig() |
static java.util.Map<java.lang.String,java.lang.Object> |
toEventLoggerConfig(java.util.Map<java.lang.String,?> originals) |
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
protected static final org.slf4j.Logger log
public static final java.lang.String AUDIT_PREFIX
public static final java.lang.String AUDIT_EVENT_LOGGER_PREFIX
public static final java.lang.String AUDIT_EVENT_ROUTER_PREFIX
public static final java.lang.String AUDIT_LOGGER_ENABLE_CONFIG
public static final java.lang.String DEFAULT_AUDIT_LOGGER_ENABLE_CONFIG
public static final java.lang.String AUDIT_LOGGER_ENABLE_DOC
public static final java.lang.String AUDIT_CLOUD_EVENT_ENCODING_CONFIG
public static final java.lang.String DEFAULT_AUDIT_CLOUD_EVENT_ENCODING_CONFIG
public static final java.lang.String AUDIT_CLOUD_EVENT_ENCODING_DOC
public static final java.lang.String EVENT_EXPORTER_CLASS_CONFIG
public static final java.lang.String DEFAULT_EVENT_EXPORTER_CLASS_CONFIG
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
public static final java.lang.String TOPIC_CREATE_CONFIG
public static final boolean DEFAULT_TOPIC_CREATE_CONFIG
public static final java.lang.String TOPIC_PARTITIONS_CONFIG
public static final int DEFAULT_TOPIC_PARTITIONS_CONFIG
public static final java.lang.String TOPIC_REPLICAS_CONFIG
public static final int DEFAULT_TOPIC_REPLICAS_CONFIG
public static final java.lang.String TOPIC_RETENTION_MS_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_MS_CONFIG
public static final java.lang.String TOPIC_RETENTION_BYTES_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_BYTES_CONFIG
public static final java.lang.String TOPIC_ROLL_MS_CONFIG
public static final long DEFAULT_TOPIC_ROLL_MS_CONFIG
public static final java.lang.String ROUTER_CONFIG
public static final java.lang.String DEFAULT_ROUTER
public static final java.lang.String ROUTER_DOC
public static final java.lang.String ROUTER_CACHE_ENTRIES_CONFIG
public static final int DEFAULT_ROUTER_CACHE_ENTRIES
public static final java.lang.String ROUTER_CACHE_ENTRIES_DOC
public static java.util.Properties kafkaProducerOverrides()
public static java.util.Properties kafkaInterBrokerClientConfig(java.util.Map<java.lang.String,?> originals)
public AuditLogRouterJsonConfig routerJsonConfig() throws org.apache.kafka.common.config.ConfigException
org.apache.kafka.common.config.ConfigException
public static java.util.Map<java.lang.String,java.lang.Object> toEventLoggerConfig(java.util.Map<java.lang.String,?> originals) throws org.apache.kafka.common.config.ConfigException
org.apache.kafka.common.config.ConfigException