io.confluent.telemetry.exporter.kafka

Class KafkaExporterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.exporter.ExporterConfig

io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

public class KafkaExporterConfig
extends ExporterConfig

Nested Class Summary

Nested classes/interfaces inherited from class io.confluent.telemetry.exporter.ExporterConfig

ExporterConfig.ExporterType

Field Summary

Fields

Modifier and Type	Field and Description
static String	BOOTSTRAP_SERVERS_CONFIG
static String	BOOTSTRAP_SERVERS_DEFAULT
static String	BOOTSTRAP_SERVERS_DOC
static boolean	DEFAULT_TOPIC_CREATE
static int	DEFAULT_TOPIC_MAX_MESSAGE_BYTES
static String	DEFAULT_TOPIC_NAME
static int	DEFAULT_TOPIC_PARTITIONS
static int	DEFAULT_TOPIC_REPLICAS
static long	DEFAULT_TOPIC_RETENTION_BYTES
static long	DEFAULT_TOPIC_RETENTION_MS
static long	DEFAULT_TOPIC_ROLL_MS
static String	PREFIX_PRODUCER
static String	PREFIX_TOPIC
static String	TOPIC_CREATE_CONFIG
static String	TOPIC_CREATE_DOC
static String	TOPIC_MAX_MESSAGE_BYTES_CONFIG
static String	TOPIC_MAX_MESSAGE_BYTES_DOC
static String	TOPIC_NAME_CONFIG
static String	TOPIC_NAME_DOC
static String	TOPIC_PARTITIONS_CONFIG
static String	TOPIC_PARTITIONS_DOC
static String	TOPIC_REPLICAS_CONFIG
static String	TOPIC_REPLICAS_DOC
static String	TOPIC_RETENTION_BYTES_CONFIG
static String	TOPIC_RETENTION_BYTES_DOC
static String	TOPIC_RETENTION_MS_CONFIG
static String	TOPIC_RETENTION_MS_DOC
static String	TOPIC_ROLL_MS_CONFIG
static String	TOPIC_ROLL_MS_DOC

Fields inherited from class io.confluent.telemetry.exporter.ExporterConfig

CLIENT_NAME_CONFIG, CLIENT_NAME_CONFIG_DEFAULT, CLIENT_NAME_CONFIG_DOC, ENABLED_CONFIG, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, METRICS_INCLUDE_CONFIG, METRICS_INCLUDE_CONFIG_DOC, NAMED_CLIENT_CONFIGURED_DOC_WARNING, RECONFIGURABLES, REMOTE_CONFIGURABLE_CONFIG, REMOTE_CONFIGURABLE_CONFIG_DEFAULT, REMOTE_CONFIGURABLE_CONFIG_DOC, TYPE_CONFIG, TYPE_CONFIG_DOC

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor and Description
KafkaExporterConfig(String name, Map<String,?> originals)
KafkaExporterConfig(String name, Map<String,?> originals, boolean doLog)
KafkaExporterConfig(String name, Map<String,?> originals, ProducerClientConfig clientConfig, boolean doLog)

Method Summary

Modifier and Type	Method and Description
ProducerClientConfig	getClientConfig()
String	getClientName()
boolean	hasNamedClient()
boolean	hasNativeClientConfigs()
static void	main(String[] args)

Methods inherited from class io.confluent.telemetry.exporter.ExporterConfig

buildMetricsPredicate, getName, getType, isEnabled, isMetricsEnabled, isRemoteConfigurable, parseType, reconfigure

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 Detail

PREFIX_PRODUCER

public static final String PREFIX_PRODUCER

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

BOOTSTRAP_SERVERS_DEFAULT

public static final String BOOTSTRAP_SERVERS_DEFAULT

See Also:

Constant Field Values

PREFIX_TOPIC

public static final String PREFIX_TOPIC

See Also:

Constant Field Values

TOPIC_NAME_CONFIG

public static final String TOPIC_NAME_CONFIG

See Also:

Constant Field Values

TOPIC_NAME_DOC

public static final String TOPIC_NAME_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_NAME

public static final String DEFAULT_TOPIC_NAME

See Also:

Constant Field Values

TOPIC_CREATE_CONFIG

public static final String TOPIC_CREATE_CONFIG

See Also:

Constant Field Values

TOPIC_CREATE_DOC

public static final String TOPIC_CREATE_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_CREATE

public static final boolean DEFAULT_TOPIC_CREATE

See Also:

Constant Field Values

TOPIC_PARTITIONS_CONFIG

public static final String TOPIC_PARTITIONS_CONFIG

See Also:

Constant Field Values

TOPIC_PARTITIONS_DOC

public static final String TOPIC_PARTITIONS_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_PARTITIONS

public static final int DEFAULT_TOPIC_PARTITIONS

See Also:

Constant Field Values

TOPIC_REPLICAS_CONFIG

public static final String TOPIC_REPLICAS_CONFIG

See Also:

Constant Field Values

TOPIC_REPLICAS_DOC

public static final String TOPIC_REPLICAS_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_REPLICAS

public static final int DEFAULT_TOPIC_REPLICAS

See Also:

Constant Field Values

TOPIC_RETENTION_MS_CONFIG

public static final String TOPIC_RETENTION_MS_CONFIG

See Also:

Constant Field Values

TOPIC_RETENTION_MS_DOC

public static final String TOPIC_RETENTION_MS_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_RETENTION_MS

public static final long DEFAULT_TOPIC_RETENTION_MS

TOPIC_RETENTION_BYTES_CONFIG

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

DEFAULT_TOPIC_RETENTION_BYTES

public static final long DEFAULT_TOPIC_RETENTION_BYTES

See Also:

Constant Field Values

TOPIC_ROLL_MS_CONFIG

public static final String TOPIC_ROLL_MS_CONFIG

See Also:

Constant Field Values

TOPIC_ROLL_MS_DOC

public static final String TOPIC_ROLL_MS_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_ROLL_MS

public static final long DEFAULT_TOPIC_ROLL_MS

TOPIC_MAX_MESSAGE_BYTES_CONFIG

public static final String TOPIC_MAX_MESSAGE_BYTES_CONFIG

See Also:

Constant Field Values

TOPIC_MAX_MESSAGE_BYTES_DOC

public static final String TOPIC_MAX_MESSAGE_BYTES_DOC

See Also:

Constant Field Values

DEFAULT_TOPIC_MAX_MESSAGE_BYTES

public static final int DEFAULT_TOPIC_MAX_MESSAGE_BYTES

See Also:

Constant Field Values

Constructor Detail

KafkaExporterConfig

public KafkaExporterConfig(String name,
                           Map<String,?> originals)

KafkaExporterConfig

public KafkaExporterConfig(String name,
                           Map<String,?> originals,
                           boolean doLog)

KafkaExporterConfig

public KafkaExporterConfig(String name,
                           Map<String,?> originals,
                           ProducerClientConfig clientConfig,
                           boolean doLog)

Parameters:

name - name of the exporter

originals - original configs

clientConfig - client config is using a configured named (static) client

doLog - whether the configurations should be logged

Method Detail

main

public static void main(String[] args)

getClientName

public String getClientName()

hasNamedClient

public boolean hasNamedClient()

hasNativeClientConfigs

public boolean hasNativeClientConfigs()

getClientConfig

public ProducerClientConfig getClientConfig()