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_DOC
static boolean	DEFAULT_SUBSET_PARTITIONER_ENABLED
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	SUBSET_PARTITIONER_ENABLED
static String	SUBSET_PARTITIONER_ENABLED_DOC
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

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, 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)

Method Summary

Modifier and Type	Method and Description
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

PREFIX_TOPIC

public static final String PREFIX_TOPIC

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

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

SUBSET_PARTITIONER_ENABLED

public static final String SUBSET_PARTITIONER_ENABLED

See Also:

Constant Field Values

SUBSET_PARTITIONER_ENABLED_DOC

public static final String SUBSET_PARTITIONER_ENABLED_DOC

See Also:

Constant Field Values

DEFAULT_SUBSET_PARTITIONER_ENABLED

public static final boolean DEFAULT_SUBSET_PARTITIONER_ENABLED

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)

Method Detail

main

public static void main(String[] args)