public class EventLoggerConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
EventLoggerConfig(java.util.Map<java.lang.String,?> configs) |
Modifier and Type | Method and Description |
---|---|
java.util.Properties |
clientProperties() |
java.util.Map<java.lang.String,java.lang.String> |
defaultTopicConfig() |
java.util.Map<java.lang.String,TopicSpec> |
getTopicSpecs() |
java.util.Properties |
producerProperties() |
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
public static final java.lang.String EVENT_LOGGER_PREFIX
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 EVENT_EXPORTER_CLASS_DOC
public static final java.lang.String EVENT_LOGGER_LOG_BLOCKING_CONFIG
public static final java.lang.Boolean DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG
public static final java.lang.String EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC
public static final java.lang.String LOG_EVENT_EXPORTER_NAME_CONFIG
public static final java.lang.String DEFAULT_LOG_EVENT_EXPORTER_NAME_CONFIG
public static final java.lang.String LOG_EVENT_EXPORTER_NAME_DOC
public static final java.lang.String KAFKA_EXPORTER_PREFIX
public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
public static final java.lang.String BOOTSTRAP_SERVERS_DOC
public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG
public static final int DEFAULT_REQUEST_TIMEOUT_MS
public static final java.lang.String REQUEST_TIMEOUT_MS_DOC
public static final java.lang.String TOPIC_CREATE_CONFIG
public static final boolean DEFAULT_TOPIC_CREATE_CONFIG
public static final java.lang.String TOPIC_CREATE_DOC
public static final java.lang.String TOPIC_PARTITIONS_CONFIG
public static final int DEFAULT_TOPIC_PARTITIONS_CONFIG
public static final java.lang.String TOPIC_PARTITIONS_DOC
public static final java.lang.String TOPIC_REPLICAS_CONFIG
public static final int DEFAULT_TOPIC_REPLICAS_CONFIG
public static final java.lang.String TOPIC_REPLICAS_DOC
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_MS_DOC
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_RETENTION_BYTES_DOC
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 TOPIC_ROLL_MS_DOC
public static final java.lang.String DEFAULT_TOPIC
public static final java.lang.String TOPIC_CONFIG
public static final java.lang.String DEFAULT_TOPIC_CONFIG
public static final java.lang.String TOPIC_CONFIG_DOC
public static final java.lang.String CLOUD_EVENT_STRUCTURED_ENCODING
public static final java.lang.String CLOUD_EVENT_BINARY_ENCODING
public static final java.lang.String CLOUD_EVENT_ENCODING_CONFIG
public static final java.lang.String DEFAULT_CLOUD_EVENT_ENCODING_CONFIG
public static final java.lang.String CLOUD_EVENT_ENCODING_DOC
public EventLoggerConfig(java.util.Map<java.lang.String,?> configs)
public java.util.Properties producerProperties()
public java.util.Properties clientProperties()
public java.util.Map<java.lang.String,java.lang.String> defaultTopicConfig()
public java.util.Map<java.lang.String,TopicSpec> getTopicSpecs() throws org.apache.kafka.common.config.ConfigException
org.apache.kafka.common.config.ConfigException