Class EventEmitterConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.events.EventEmitterConfig

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

EventEmitterConfig uses a hash map to save exporter configs, key is event type: events/metrics, value is a hash map, key is exporter name, value is a map of exporter configs. Actual ExporterConfig will be created when create when exporter is created. In ce-metrics, ConfluentTelemetryConfig uses a hash map to save exporter configs, key is exporter name, value is ExporterConfig instance, so it can utilize helper method from ExporterConfig TODO: consolidate EventEmitterConfig and ConfluentTelemetryConfig, jira: https://confluentinc.atlassian.net/browse/EVENTS-320

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	EventEmitterConfig.EventType

Field Summary

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
EventEmitterConfig(Map<String,?> configs)

Method Summary

Modifier and Type	Method	Description
Map<String, Map<String,Object>>	getEnabledExporterConfigs(EventEmitterConfig.EventType eventType)	Get exporter configs of a certain event type, only enabled exporters are returned
Map<String, Map<String,Object>>	getNonInternalExporterConfigs(EventEmitterConfig.EventType dataType)
boolean	isEventExporter(Map<String,Object> exporterConfig)
boolean	isEventsExporterEnabled(Map<String,Object> exporterConfig)
boolean	isHttpExporter(Map<String,Object> exporterConfig)
boolean	isInternalExporter(String exporterName)
boolean	isKafkaExporter(Map<String,Object> exporterConfig)

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

Constructor Details

EventEmitterConfig

public EventEmitterConfig(Map<String,?> configs)

Method Details

getEnabledExporterConfigs

public Map<String, Map<String,Object>> getEnabledExporterConfigs(EventEmitterConfig.EventType eventType)

Get exporter configs of a certain event type, only enabled exporters are returned

Parameters:

eventType - : events or metrics

Returns:

A hashmap of all enabled exporters of this event type, key is exporter name, value is a hashmap with all properties of this exporter, property name of this exporter will have event type prefix stripped off

getNonInternalExporterConfigs

public Map<String, Map<String,Object>> getNonInternalExporterConfigs(EventEmitterConfig.EventType dataType)

isKafkaExporter

public boolean isKafkaExporter(Map<String,Object> exporterConfig)

isHttpExporter

public boolean isHttpExporter(Map<String,Object> exporterConfig)

isInternalExporter

public boolean isInternalExporter(String exporterName)

isEventExporter

public boolean isEventExporter(Map<String,Object> exporterConfig)

isEventsExporterEnabled

public boolean isEventsExporterEnabled(Map<String,Object> exporterConfig)