public class LogEventsConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static String |
AUTHORITY_NAME |
static String |
CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX |
static String |
CONFLUENT_EVENT_LOGGER_PREFIX |
static String |
CONFLUENT_PREFIX |
static String |
DEFAULT_EVENT_EXPORTER_CLASS_CONFIG |
static String |
DEFAULT_LOGGER_BOOTSTRAP_SERVERS |
static String |
DEFAULT_LOGGER_CLIENT_ID |
static String |
DEFAULT_LOGGER_ENABLE |
static String |
DEFAULT_TOPIC |
static boolean |
DEFAULT_TOPIC_CREATE_CONFIG |
static String |
LOGGER_BOOTSTRAP_SERVERS_CONFIG |
static String |
LOGGER_CLIENT_ID_CONFIG |
static String |
LOGGER_CLIENT_ID_DOC |
static String |
LOGGER_CLOUD_EVENT_ENCODING_CONFIG |
static String |
LOGGER_ENABLE_CONFIG |
static String |
LOGGER_ENABLE_DOC |
static String |
LOGGER_EVENT_EXPORTER_CLASS_CONFIG |
static String |
LOGGER_EXPORTER_TYPE_CONFIG |
static String |
LOGGER_EXPORTER_TYPE_DEFAULT |
static String |
LOGGER_LOG_EVENTS_TOPIC_CONFIG |
static String |
LOGGER_TOPIC_CREATE_CONFIG |
Constructor and Description |
---|
LogEventsConfig(Map<?,?> originals) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
toEventLoggerConfig()
Return only configs prefixed by `confluent.event.logger` from LogEventsConfigs defaults as well
as WorkerConfigs for LogEventsKafkaEmitter#eventLogger.
|
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String CONFLUENT_PREFIX
public static final String CONFLUENT_EVENT_LOGGER_PREFIX
public static final String CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX
public static final String LOGGER_ENABLE_CONFIG
public static final String DEFAULT_LOGGER_ENABLE
public static final String LOGGER_ENABLE_DOC
public static final String LOGGER_BOOTSTRAP_SERVERS_CONFIG
public static final String DEFAULT_LOGGER_BOOTSTRAP_SERVERS
public static final String LOGGER_EVENT_EXPORTER_CLASS_CONFIG
public static final String DEFAULT_EVENT_EXPORTER_CLASS_CONFIG
public static final String LOGGER_CLOUD_EVENT_ENCODING_CONFIG
public static final String LOGGER_TOPIC_CREATE_CONFIG
public static final boolean DEFAULT_TOPIC_CREATE_CONFIG
public static final String LOGGER_EXPORTER_TYPE_CONFIG
public static final String LOGGER_EXPORTER_TYPE_DEFAULT
public static final String LOGGER_LOG_EVENTS_TOPIC_CONFIG
public static final String DEFAULT_TOPIC
public static final String LOGGER_CLIENT_ID_CONFIG
public static final String LOGGER_CLIENT_ID_DOC
public static final String DEFAULT_LOGGER_CLIENT_ID
public static final String AUTHORITY_NAME
public LogEventsConfig(Map<?,?> originals)
public Map<String,Object> toEventLoggerConfig() throws org.apache.kafka.common.config.ConfigException
EventLogger
org.apache.kafka.common.config.ConfigException