public class EventEmitterConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Class and Description |
---|---|
static class |
EventEmitterConfig.EventType |
Constructor and Description |
---|
EventEmitterConfig(Map<String,?> configs) |
Modifier and Type | Method and 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 |
isInternalExporter(String exporterName) |
boolean |
isKafkaExporter(Map<String,Object> exporterConfig) |
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
public Map<String,Map<String,Object>> getEnabledExporterConfigs(EventEmitterConfig.EventType eventType)
eventType:
- events or metricspublic Map<String,Map<String,Object>> getNonInternalExporterConfigs(EventEmitterConfig.EventType dataType)
public boolean isInternalExporter(String exporterName)