public abstract class ExporterConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Class and Description |
---|---|
static class |
ExporterConfig.ExporterType |
Modifier and Type | Field and Description |
---|---|
static String |
ENABLED_CONFIG |
static String |
ENABLED_CONFIG_DOC |
static String |
EVENTS_ENABLED_CONFIG |
static boolean |
EVENTS_ENABLED_CONFIG_DEFAULT |
static String |
EVENTS_ENABLED_CONFIG_DOC |
static String |
METRICS_ENABLED_CONFIG |
static boolean |
METRICS_ENABLED_CONFIG_DEFAULT |
static String |
METRICS_ENABLED_CONFIG_DOC |
static String |
METRICS_INCLUDE_CONFIG |
static String |
METRICS_INCLUDE_CONFIG_DOC |
static Set<String> |
RECONFIGURABLES |
static String |
TYPE_CONFIG |
static String |
TYPE_CONFIG_DOC |
Constructor and Description |
---|
ExporterConfig(org.apache.kafka.common.config.ConfigDef definition,
Map<?,?> originals) |
ExporterConfig(org.apache.kafka.common.config.ConfigDef definition,
Map<?,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
Optional<Predicate<Keyed>> |
buildMetricsPredicate()
Gets the exporter specific predicated if the `metrics.include` is set.
|
ExporterConfig.ExporterType |
getType() |
boolean |
isEnabled() |
boolean |
isMetricsEnabled() |
static ExporterConfig.ExporterType |
parseType(Object value) |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String ENABLED_CONFIG
public static final String ENABLED_CONFIG_DOC
public static final String TYPE_CONFIG
public static final String TYPE_CONFIG_DOC
public static final String METRICS_INCLUDE_CONFIG
public static final String METRICS_INCLUDE_CONFIG_DOC
public static final String METRICS_ENABLED_CONFIG
public static final String METRICS_ENABLED_CONFIG_DOC
public static final boolean METRICS_ENABLED_CONFIG_DEFAULT
public static final String EVENTS_ENABLED_CONFIG
public static final String EVENTS_ENABLED_CONFIG_DOC
public static final boolean EVENTS_ENABLED_CONFIG_DEFAULT
public ExporterConfig(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals)
public ExporterConfig(org.apache.kafka.common.config.ConfigDef definition, Map<?,?> originals, boolean doLog)
public static ExporterConfig.ExporterType parseType(Object value)
public ExporterConfig.ExporterType getType()
public boolean isEnabled()
public boolean isMetricsEnabled()