Class LogEventsConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.logevents.connect.LogEventsConfig

public class LogEventsConfig
extends org.apache.kafka.common.config.AbstractConfig

LogEventsConfig class defining configurations needed for capturing Connect log events.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AUTHORITY_NAME
static final String	CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX
static final String	CONFLUENT_EVENT_LOGGER_PREFIX
static final String	CONFLUENT_LOG_PREFIX_REMOTE_CONFIG
static final String	CONFLUENT_LOG_REMOTE_CONFIG_CLOUD
static final String	CONFLUENT_PREFIX
static final String	DEFAULT_EVENT_EXPORTER_CLASS_CONFIG
static final String	DEFAULT_LOGGER_BOOTSTRAP_SERVERS
static final String	DEFAULT_LOGGER_CLIENT_ID
static final String	DEFAULT_LOGGER_ENABLE
static final String	DEFAULT_TOPIC
static final boolean	DEFAULT_TOPIC_CREATE_CONFIG
static final String	LOG_EVENTS_DEDUPLICATE_ERRORS
static final Long	LOG_EVENTS_FAILURE_EVENT_MAP_CLEANUP_TIME_DEFAULT
static final String	LOG_EVENTS_FAILURE_EVENT_RESET_TIME
static final String	LOGGER_BOOTSTRAP_SERVERS_CONFIG
static final String	LOGGER_CLIENT_ID_CONFIG
static final String	LOGGER_CLIENT_ID_DOC
static final String	LOGGER_CLOUD_EVENT_ENCODING_CONFIG
static final String	LOGGER_ENABLE_CONFIG
static final String	LOGGER_ENABLE_DOC
static final String	LOGGER_EVENT_EXPORTER_CLASS_CONFIG
static final String	LOGGER_EXPORTER_TYPE_CONFIG
static final String	LOGGER_EXPORTER_TYPE_DEFAULT
static final String	LOGGER_LOG_EVENTS_TOPIC_CONFIG
static final String	LOGGER_TOPIC_CREATE_CONFIG
static final String	NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED
static final boolean	NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DEFAULT
static final String	NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DOC

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG, CONFIG_PROVIDERS_DOC

Constructor Summary

Constructors

Constructor	Description
LogEventsConfig(Map<?,?> originals)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

CONFLUENT_PREFIX

public static final String CONFLUENT_PREFIX

See Also:

• Constant Field Values

CONFLUENT_EVENT_LOGGER_PREFIX

public static final String CONFLUENT_EVENT_LOGGER_PREFIX

See Also:

• Constant Field Values

CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX

public static final String CONFLUENT_EVENT_LOGGER_KAFKA_EXPORTER_PREFIX

See Also:

• Constant Field Values

LOGGER_ENABLE_CONFIG

public static final String LOGGER_ENABLE_CONFIG

See Also:

• Constant Field Values

DEFAULT_LOGGER_ENABLE

public static final String DEFAULT_LOGGER_ENABLE

See Also:

• Constant Field Values

LOGGER_ENABLE_DOC

public static final String LOGGER_ENABLE_DOC

See Also:

• Constant Field Values

LOGGER_BOOTSTRAP_SERVERS_CONFIG

public static final String LOGGER_BOOTSTRAP_SERVERS_CONFIG

See Also:

• Constant Field Values

DEFAULT_LOGGER_BOOTSTRAP_SERVERS

public static final String DEFAULT_LOGGER_BOOTSTRAP_SERVERS

See Also:

• Constant Field Values

LOGGER_EVENT_EXPORTER_CLASS_CONFIG

public static final String LOGGER_EVENT_EXPORTER_CLASS_CONFIG

See Also:

• Constant Field Values

DEFAULT_EVENT_EXPORTER_CLASS_CONFIG

public static final String DEFAULT_EVENT_EXPORTER_CLASS_CONFIG

LOGGER_CLOUD_EVENT_ENCODING_CONFIG

public static final String LOGGER_CLOUD_EVENT_ENCODING_CONFIG

See Also:

• Constant Field Values

LOGGER_TOPIC_CREATE_CONFIG

public static final String LOGGER_TOPIC_CREATE_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_CREATE_CONFIG

public static final boolean DEFAULT_TOPIC_CREATE_CONFIG

See Also:

• Constant Field Values

LOGGER_EXPORTER_TYPE_CONFIG

public static final String LOGGER_EXPORTER_TYPE_CONFIG

See Also:

• Constant Field Values

LOGGER_EXPORTER_TYPE_DEFAULT

public static final String LOGGER_EXPORTER_TYPE_DEFAULT

LOGGER_LOG_EVENTS_TOPIC_CONFIG

public static final String LOGGER_LOG_EVENTS_TOPIC_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

See Also:

• Constant Field Values

LOGGER_CLIENT_ID_CONFIG

public static final String LOGGER_CLIENT_ID_CONFIG

See Also:

• Constant Field Values

LOGGER_CLIENT_ID_DOC

public static final String LOGGER_CLIENT_ID_DOC

See Also:

• Constant Field Values

DEFAULT_LOGGER_CLIENT_ID

public static final String DEFAULT_LOGGER_CLIENT_ID

See Also:

• Constant Field Values

LOG_EVENTS_DEDUPLICATE_ERRORS

public static final String LOG_EVENTS_DEDUPLICATE_ERRORS

See Also:

• Constant Field Values

LOG_EVENTS_FAILURE_EVENT_RESET_TIME

public static final String LOG_EVENTS_FAILURE_EVENT_RESET_TIME

See Also:

• Constant Field Values

LOG_EVENTS_FAILURE_EVENT_MAP_CLEANUP_TIME_DEFAULT

public static final Long LOG_EVENTS_FAILURE_EVENT_MAP_CLEANUP_TIME_DEFAULT

AUTHORITY_NAME

public static final String AUTHORITY_NAME

See Also:

• Constant Field Values

NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED

public static final String NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED

See Also:

• Constant Field Values

NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DEFAULT

public static final boolean NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DEFAULT

See Also:

• Constant Field Values

NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DOC

public static final String NAMED_BOOTSTRAP_SERVERS_CONFIG_ENABLED_DOC

See Also:

• Constant Field Values

CONFLUENT_LOG_PREFIX_REMOTE_CONFIG

public static final String CONFLUENT_LOG_PREFIX_REMOTE_CONFIG

See Also:

• Constant Field Values

CONFLUENT_LOG_REMOTE_CONFIG_CLOUD

public static final String CONFLUENT_LOG_REMOTE_CONFIG_CLOUD

See Also:

• Constant Field Values

Constructor Details

LogEventsConfig

public LogEventsConfig(Map<?,?> originals)

Method Details

toEventLoggerConfig

public Map<String,Object> toEventLoggerConfig()
                                       throws org.apache.kafka.common.config.ConfigException

Return only configs prefixed by `confluent.event.logger` from LogEventsConfigs defaults as well as WorkerConfigs for LogEventsKafkaEmitter#eventLogger.

Returns:

Properties needed for configuring EventLogger

Throws:

org.apache.kafka.common.config.ConfigException

logEventsDeduplicateErrors

public Boolean logEventsDeduplicateErrors()

logFailureEventResetTime

public long logFailureEventResetTime()