Class NonBlockingKafkaExporterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.security.audit.telemetry.exporter.NonBlockingKafkaExporterConfig

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BOOTSTRAP_SERVERS_CONFIG
static final String	BOOTSTRAP_SERVERS_DOC
static final Boolean	DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG
static final int	DEFAULT_REQUEST_TIMEOUT_MS
static final String	DEFAULT_TOPIC
static final String	DEFAULT_TOPIC_CONFIG
static final boolean	DEFAULT_TOPIC_CREATE_CONFIG
static final int	DEFAULT_TOPIC_PARTITIONS_CONFIG
static final int	DEFAULT_TOPIC_REPLICAS_CONFIG
static final long	DEFAULT_TOPIC_RETENTION_BYTES_CONFIG
static final long	DEFAULT_TOPIC_RETENTION_MS_CONFIG
static final long	DEFAULT_TOPIC_ROLL_MS_CONFIG
static final String	EVENT_LOGGER_LOG_BLOCKING_CONFIG
static final String	EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC
static final String	KAFKA_EXPORTER_PREFIX
static final String	PRODUCER_PREFIX
static final String	REQUEST_TIMEOUT_MS_CONFIG
static final String	REQUEST_TIMEOUT_MS_DOC
static final String	TOPIC_CONFIG
static final String	TOPIC_CONFIG_DOC
static final String	TOPIC_CREATE_CONFIG
static final String	TOPIC_CREATE_DOC
static final String	TOPIC_PARTITIONS_CONFIG
static final String	TOPIC_PARTITIONS_DOC
static final String	TOPIC_REPLICAS_CONFIG
static final String	TOPIC_REPLICAS_DOC
static final String	TOPIC_RETENTION_BYTES_CONFIG
static final String	TOPIC_RETENTION_BYTES_DOC
static final String	TOPIC_RETENTION_MS_CONFIG
static final String	TOPIC_RETENTION_MS_DOC
static final String	TOPIC_ROLL_MS_CONFIG
static final String	TOPIC_ROLL_MS_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
NonBlockingKafkaExporterConfig(Map<String,?> configs)

Method Summary

Modifier and Type	Method	Description
Properties	clientProperties(Set<String> allowedKeys)
Properties	clientProperties(Set<String> allowedKeys, String prefix)
Map<String,String>	defaultTopicConfig()
Map<String, TopicSpec>	getTopicSpecs()
Properties	producerProperties()

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

KAFKA_EXPORTER_PREFIX

public static final String KAFKA_EXPORTER_PREFIX

See Also:

• Constant Field Values

PRODUCER_PREFIX

public static final String PRODUCER_PREFIX

See Also:

• Constant Field Values

EVENT_LOGGER_LOG_BLOCKING_CONFIG

public static final String EVENT_LOGGER_LOG_BLOCKING_CONFIG

See Also:

• Constant Field Values

DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG

public static final Boolean DEFAULT_EVENT_LOGGER_LOG_BLOCKING_CONFIG

EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC

public static final String EVENT_LOGGER_LOG_BLOCKING_CONFIG_DOC

See Also:

• Constant Field Values

BOOTSTRAP_SERVERS_CONFIG

public static final String BOOTSTRAP_SERVERS_CONFIG

See Also:

• Constant Field Values

BOOTSTRAP_SERVERS_DOC

public static final String BOOTSTRAP_SERVERS_DOC

See Also:

• Constant Field Values

REQUEST_TIMEOUT_MS_CONFIG

public static final String REQUEST_TIMEOUT_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_REQUEST_TIMEOUT_MS

public static final int DEFAULT_REQUEST_TIMEOUT_MS

See Also:

• Constant Field Values

REQUEST_TIMEOUT_MS_DOC

public static final String REQUEST_TIMEOUT_MS_DOC

See Also:

• Constant Field Values

TOPIC_CREATE_CONFIG

public static final String 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

TOPIC_CREATE_DOC

public static final String TOPIC_CREATE_DOC

See Also:

• Constant Field Values

TOPIC_PARTITIONS_CONFIG

public static final String TOPIC_PARTITIONS_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_PARTITIONS_CONFIG

public static final int DEFAULT_TOPIC_PARTITIONS_CONFIG

See Also:

• Constant Field Values

TOPIC_PARTITIONS_DOC

public static final String TOPIC_PARTITIONS_DOC

See Also:

• Constant Field Values

TOPIC_REPLICAS_CONFIG

public static final String TOPIC_REPLICAS_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_REPLICAS_CONFIG

public static final int DEFAULT_TOPIC_REPLICAS_CONFIG

See Also:

• Constant Field Values

TOPIC_REPLICAS_DOC

public static final String TOPIC_REPLICAS_DOC

See Also:

• Constant Field Values

TOPIC_RETENTION_MS_CONFIG

public static final String TOPIC_RETENTION_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_RETENTION_MS_CONFIG

public static final long DEFAULT_TOPIC_RETENTION_MS_CONFIG

TOPIC_RETENTION_MS_DOC

public static final String TOPIC_RETENTION_MS_DOC

See Also:

• Constant Field Values

TOPIC_RETENTION_BYTES_CONFIG

public static final String TOPIC_RETENTION_BYTES_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_RETENTION_BYTES_CONFIG

public static final long DEFAULT_TOPIC_RETENTION_BYTES_CONFIG

See Also:

• Constant Field Values

TOPIC_RETENTION_BYTES_DOC

public static final String TOPIC_RETENTION_BYTES_DOC

See Also:

• Constant Field Values

TOPIC_ROLL_MS_CONFIG

public static final String TOPIC_ROLL_MS_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_ROLL_MS_CONFIG

public static final long DEFAULT_TOPIC_ROLL_MS_CONFIG

TOPIC_ROLL_MS_DOC

public static final String TOPIC_ROLL_MS_DOC

See Also:

• Constant Field Values

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

See Also:

• Constant Field Values

TOPIC_CONFIG

public static final String TOPIC_CONFIG

See Also:

• Constant Field Values

DEFAULT_TOPIC_CONFIG

public static final String DEFAULT_TOPIC_CONFIG

See Also:

• Constant Field Values

TOPIC_CONFIG_DOC

public static final String TOPIC_CONFIG_DOC

See Also:

• Constant Field Values

Constructor Details

NonBlockingKafkaExporterConfig

public NonBlockingKafkaExporterConfig(Map<String,?> configs)

Method Details

producerProperties

public Properties producerProperties()

clientProperties

public Properties clientProperties(Set<String> allowedKeys,
 String prefix)

clientProperties

public Properties clientProperties(Set<String> allowedKeys)

defaultTopicConfig

public Map<String,String> defaultTopicConfig()

getTopicSpecs

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

Throws:

org.apache.kafka.common.config.ConfigException