public class AuditLogConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static String |
AUDIT_CLOUD_EVENT_ENCODING_CONFIG |
static String |
AUDIT_CLOUD_EVENT_ENCODING_DOC |
static String |
BOOTSTRAP_SERVERS_CONFIG |
static String |
DEFAULT_AUDIT_CLOUD_EVENT_ENCODING_CONFIG |
static String |
DEFAULT_EVENT_EXPORTER_CLASS_CONFIG |
static int |
DEFAULT_ROUTER_CACHE_ENTRIES |
static boolean |
DEFAULT_TOPIC_CREATE_CONFIG |
static int |
DEFAULT_TOPIC_PARTITIONS_CONFIG |
static long |
DEFAULT_TOPIC_RETENTION_BYTES_CONFIG |
static long |
DEFAULT_TOPIC_RETENTION_MS_CONFIG |
static long |
DEFAULT_TOPIC_ROLL_MS_CONFIG |
static String |
EVENT_EXPORTER_CLASS_CONFIG |
static String |
ROUTER_CACHE_ENTRIES_CONFIG |
static String |
ROUTER_CACHE_ENTRIES_DOC |
static String |
TOPIC_CREATE_CONFIG |
static String |
TOPIC_PARTITIONS_CONFIG |
static String |
TOPIC_RETENTION_BYTES_CONFIG |
static String |
TOPIC_RETENTION_MS_CONFIG |
static String |
TOPIC_ROLL_MS_CONFIG |
Constructor and Description |
---|
AuditLogConfig(Map<String,?> configs) |
Modifier and Type | Method and Description |
---|---|
static Map<String,?> |
kafkaInterBrokerClientConfig(Map<String,?> originals) |
static Properties |
kafkaProducerOverrides() |
AuditLogRouterJsonConfig |
routerJsonConfig() |
static Map<String,Object> |
toEventLoggerConfig(Map<String,?> originals) |
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
public static final String AUDIT_CLOUD_EVENT_ENCODING_CONFIG
public static final String DEFAULT_AUDIT_CLOUD_EVENT_ENCODING_CONFIG
public static final String AUDIT_CLOUD_EVENT_ENCODING_DOC
public static final String EVENT_EXPORTER_CLASS_CONFIG
public static final String DEFAULT_EVENT_EXPORTER_CLASS_CONFIG
public static final String BOOTSTRAP_SERVERS_CONFIG
public static final String TOPIC_CREATE_CONFIG
public static final boolean DEFAULT_TOPIC_CREATE_CONFIG
public static final String TOPIC_PARTITIONS_CONFIG
public static final int DEFAULT_TOPIC_PARTITIONS_CONFIG
public static final String TOPIC_RETENTION_MS_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_MS_CONFIG
public static final String TOPIC_RETENTION_BYTES_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_BYTES_CONFIG
public static final String TOPIC_ROLL_MS_CONFIG
public static final long DEFAULT_TOPIC_ROLL_MS_CONFIG
public static final String ROUTER_CACHE_ENTRIES_CONFIG
public static final int DEFAULT_ROUTER_CACHE_ENTRIES
public static final String ROUTER_CACHE_ENTRIES_DOC
public static Properties kafkaProducerOverrides()
public static Map<String,?> kafkaInterBrokerClientConfig(Map<String,?> originals)
public AuditLogRouterJsonConfig routerJsonConfig() throws org.apache.kafka.common.config.ConfigException
org.apache.kafka.common.config.ConfigException