public class LogEventsConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
LogEventsConfig(Map<?,?> originals) |
Modifier and Type | Method and Description |
---|---|
Boolean |
logEventsDeduplicateErrors() |
long |
logFailureEventResetTime() |
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 LOG_EVENTS_DEDUPLICATE_ERRORS
protected static final Boolean LOG_EVENTS_DEDUPLICATE_ERRORS_DEFAULT
protected static final String LOG_EVENTS_DEDUPLICATE_ERRORS_DOC
public static final String LOG_EVENTS_FAILURE_EVENT_RESET_TIME
protected static final String LOG_EVENTS_FAILURE_EVENT_RESET_TIME_DOC
public static final Long LOG_EVENTS_FAILURE_EVENT_MAP_CLEANUP_TIME_DEFAULT
protected static final Long LOG_EVENTS_FAILURE_EVENT_RESET_TIME_DEFAULT
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
public Boolean logEventsDeduplicateErrors()
public long logFailureEventResetTime()