Class KafkaExporterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.events.exporter.ExporterConfig

io.confluent.telemetry.events.exporter.kafka.KafkaExporterConfig

public class KafkaExporterConfig
extends ExporterConfig

Nested Class Summary

Nested classes/interfaces inherited from class ExporterConfig

ExporterConfig.ExporterType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BOOTSTRAP_SERVERS_CONFIG
static final String	BOOTSTRAP_SERVERS_DOC
static final String	CLOUD_EVENT_BINARY_ENCODING
static final String	CLOUD_EVENT_ENCODING_CONFIG
static final String	CLOUD_EVENT_ENCODING_DOC
static final String	CLOUD_EVENT_STRUCTURED_ENCODING
static final String	DEFAULT_CLOUD_EVENT_ENCODING_CONFIG
static final int	DEFAULT_EVENT_QUEUE_SIZE
static final boolean	DEFAULT_FILTERING_ENABLED
static final int	DEFAULT_MIN_ISR
static final int	DEFAULT_PRODUCER_CLOSE_TIMEOUT
static final List<String>	DEFAULT_ROUTES_ALLOWED
static final boolean	DEFAULT_SUBSET_PARTITIONER_ENABLED
static final boolean	DEFAULT_TOPIC_CREATE
static final int	DEFAULT_TOPIC_MAX_MESSAGE_BYTES
static final String	DEFAULT_TOPIC_NAME
static final int	DEFAULT_TOPIC_PARTITIONS
static final int	DEFAULT_TOPIC_REPLICAS
static final long	DEFAULT_TOPIC_RETENTION_BYTES
static final long	DEFAULT_TOPIC_RETENTION_MS
static final long	DEFAULT_TOPIC_ROLL_MS
static final String	EVENT_QUEUE_SIZE
static final String	EVENT_QUEUE_SIZE_DOC
static final String	FILTERING_ENABLED
static final String	FILTERING_ENABLED_DOC
static final int	MAX_REQUEST_SIZE
static final String	PREFIX_PRODUCER
static final String	PREFIX_TOPIC
static final Map<String,Object>	PRODUCER_CONFIG_DEFAULTS
static final Set<String>	RECONFIGURABLE_CONFIGS
static final String	ROUTES_ALLOWED
static final String	ROUTES_ALLOWED_DOC
static final String	SUBSET_PARTITIONER_ENABLED
static final String	SUBSET_PARTITIONER_ENABLED_DOC
static final String	TOPIC_CREATE_CONFIG
static final String	TOPIC_CREATE_DOC
static final String	TOPIC_MAX_MESSAGE_BYTES_CONFIG
static final String	TOPIC_MAX_MESSAGE_BYTES_DOC
static final String	TOPIC_NAME_CONFIG
static final String	TOPIC_NAME_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 ExporterConfig

ENABLED_CONFIG, ENABLED_CONFIG_DEFAULT, ENABLED_CONFIG_DOC, EVENTS_ENABLED_CONFIG, EVENTS_ENABLED_CONFIG_DEFAULT, EVENTS_ENABLED_CONFIG_DOC, EXPORTER_COMMON_CONFIG_PREFIXES, EXPORTER_COMMON_CONFIGS, METRICS_ENABLED_CONFIG, METRICS_ENABLED_CONFIG_DEFAULT, METRICS_ENABLED_CONFIG_DOC, PREFIX_EVENTS, PREFIX_EXPORTER, RECONFIGURABLES, TYPE_CONFIG, TYPE_CONFIG_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
KafkaExporterConfig(Map<String,?> originals)

Method Summary

Modifier and Type	Method	Description
Set<String>	getAllowedRoutes()
io.cloudevents.core.message.Encoding	getEncoding()
boolean	isFilteringEnabled()
static void	main(String[] args)

Methods inherited from class ExporterConfig

parseType

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 Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

MAX_REQUEST_SIZE

public static final int MAX_REQUEST_SIZE

See Also:

• Constant Field Values

DEFAULT_MIN_ISR

public static final int DEFAULT_MIN_ISR

See Also:

• Constant Field Values

PRODUCER_CONFIG_DEFAULTS

public static final Map<String,Object> PRODUCER_CONFIG_DEFAULTS

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

CLOUD_EVENT_STRUCTURED_ENCODING

public static final String CLOUD_EVENT_STRUCTURED_ENCODING

See Also:

• Constant Field Values

CLOUD_EVENT_BINARY_ENCODING

public static final String CLOUD_EVENT_BINARY_ENCODING

See Also:

• Constant Field Values

CLOUD_EVENT_ENCODING_CONFIG

public static final String CLOUD_EVENT_ENCODING_CONFIG

See Also:

• Constant Field Values

DEFAULT_CLOUD_EVENT_ENCODING_CONFIG

public static final String DEFAULT_CLOUD_EVENT_ENCODING_CONFIG

See Also:

• Constant Field Values

CLOUD_EVENT_ENCODING_DOC

public static final String CLOUD_EVENT_ENCODING_DOC

See Also:

• Constant Field Values

EVENT_QUEUE_SIZE

public static final String EVENT_QUEUE_SIZE

See Also:

• Constant Field Values

EVENT_QUEUE_SIZE_DOC

public static final String EVENT_QUEUE_SIZE_DOC

See Also:

• Constant Field Values

DEFAULT_EVENT_QUEUE_SIZE

public static final int DEFAULT_EVENT_QUEUE_SIZE

See Also:

• Constant Field Values

RECONFIGURABLE_CONFIGS

public static final Set<String> RECONFIGURABLE_CONFIGS

DEFAULT_PRODUCER_CLOSE_TIMEOUT

public static final int DEFAULT_PRODUCER_CLOSE_TIMEOUT

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

FILTERING_ENABLED

public static final String FILTERING_ENABLED

See Also:

• Constant Field Values

FILTERING_ENABLED_DOC

public static final String FILTERING_ENABLED_DOC

See Also:

• Constant Field Values

DEFAULT_FILTERING_ENABLED

public static final boolean DEFAULT_FILTERING_ENABLED

See Also:

• Constant Field Values

ROUTES_ALLOWED

public static final String ROUTES_ALLOWED

See Also:

• Constant Field Values

ROUTES_ALLOWED_DOC

public static final String ROUTES_ALLOWED_DOC

See Also:

• Constant Field Values

DEFAULT_ROUTES_ALLOWED

public static final List<String> DEFAULT_ROUTES_ALLOWED

Constructor Details

KafkaExporterConfig

public KafkaExporterConfig(Map<String,?> originals)

Method Details

main

public static void main(String[] args)

isFilteringEnabled

public boolean isFilteringEnabled()

getAllowedRoutes

public Set<String> getAllowedRoutes()

getEncoding

public io.cloudevents.core.message.Encoding getEncoding()