public class NonBlockingKafkaExporterConfig
extends org.apache.kafka.common.config.AbstractConfig
Constructor and Description |
---|
NonBlockingKafkaExporterConfig(Map<String,?> configs) |
Modifier and Type | Method and Description |
---|---|
Properties |
clientProperties(Set<String> allowedKeys) |
Properties |
clientProperties(Set<String> allowedKeys,
String prefix) |
Map<String,String> |
defaultTopicConfig() |
Map<String,TopicSpec> |
getTopicSpecs() |
Properties |
producerProperties() |
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
public static final String KAFKA_EXPORTER_PREFIX
public static final String PRODUCER_PREFIX
public static final String EVENT_LOGGER_LOG_BLOCKING_CONFIG
public static final Boolean DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG
public static final String EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC
public static final String BOOTSTRAP_SERVERS_CONFIG
public static final String BOOTSTRAP_SERVERS_DOC
public static final String REQUEST_TIMEOUT_MS_CONFIG
public static final int DEFAULT_REQUEST_TIMEOUT_MS
public static final String REQUEST_TIMEOUT_MS_DOC
public static final String TOPIC_CREATE_CONFIG
public static final boolean DEFAULT_TOPIC_CREATE_CONFIG
public static final String TOPIC_CREATE_DOC
public static final String TOPIC_PARTITIONS_CONFIG
public static final int DEFAULT_TOPIC_PARTITIONS_CONFIG
public static final String TOPIC_PARTITIONS_DOC
public static final String TOPIC_REPLICAS_CONFIG
public static final int DEFAULT_TOPIC_REPLICAS_CONFIG
public static final String TOPIC_REPLICAS_DOC
public static final String TOPIC_RETENTION_MS_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_MS_CONFIG
public static final String TOPIC_RETENTION_MS_DOC
public static final String TOPIC_RETENTION_BYTES_CONFIG
public static final long DEFAULT_TOPIC_RETENTION_BYTES_CONFIG
public static final String TOPIC_RETENTION_BYTES_DOC
public static final String TOPIC_ROLL_MS_CONFIG
public static final long DEFAULT_TOPIC_ROLL_MS_CONFIG
public static final String TOPIC_ROLL_MS_DOC
public static final String DEFAULT_TOPIC
public static final String TOPIC_CONFIG
public static final String DEFAULT_TOPIC_CONFIG
public static final String TOPIC_CONFIG_DOC
public Properties producerProperties()
public Properties clientProperties(Set<String> allowedKeys, String prefix)
public Properties clientProperties(Set<String> allowedKeys)