public class NonBlockingKafkaExporterConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
NonBlockingKafkaExporterConfig(java.util.Map<java.lang.String,?> configs) |
Modifier and Type | Method and Description |
---|---|
java.util.Properties |
clientProperties(java.util.Set<java.lang.String> allowedKeys) |
java.util.Map<java.lang.String,java.lang.String> |
defaultTopicConfig() |
java.util.Map<java.lang.String,TopicSpec> |
getTopicSpecs() |
java.util.Properties |
producerProperties() |
documentationOf, 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 KAFKA_EXPORTER_PREFIX
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 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 NonBlockingKafkaExporterConfig(java.util.Map<java.lang.String,?> configs)
public java.util.Properties producerProperties()
public java.util.Properties clientProperties(java.util.Set<java.lang.String> allowedKeys)
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