public class ConfluentTelemetryConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Field and Description |
---|---|
static java.util.function.Predicate<MetricKey> |
ALWAYS_TRUE |
static java.lang.String |
COLLECT_INTERVAL_CONFIG |
static java.lang.String |
COLLECT_INTERVAL_DOC |
static java.lang.String |
DEBUG_ENABLED |
static java.lang.String |
DEBUG_ENABLED_DOC |
static java.util.List<java.lang.String> |
DEFAULT_BROKER_MONITORING_METRICS |
static java.lang.Long |
DEFAULT_COLLECT_INTERVAL |
static boolean |
DEFAULT_DEBUG_ENABLED |
static java.lang.String |
DEFAULT_WHITELIST |
static java.lang.String |
EXPORTER_HTTP_ENABLED_CONFIG |
static boolean |
EXPORTER_HTTP_ENABLED_DEFAULT |
static java.lang.String |
EXPORTER_HTTP_ENABLED_DOC |
static java.lang.String |
EXPORTER_KAFKA_ENABLED_CONFIG |
static boolean |
EXPORTER_KAFKA_ENABLED_DEFAULT |
static java.lang.String |
EXPORTER_KAFKA_ENABLED_DOC |
static java.lang.String |
LEGACY_PREFIX |
static java.lang.String |
PREFIX |
static java.lang.String |
PREFIX_EXPORTER |
static java.lang.String |
PREFIX_LABELS |
static java.lang.String |
PREFIX_METRICS_COLLECTOR |
static java.lang.String |
WHITELIST_CONFIG |
static java.lang.String |
WHITELIST_DOC |
Constructor and Description |
---|
ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals) |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<HttpExporterConfig> |
createHttpExporterConfig()
Create a
HttpExporterConfig from these properties if enabled |
java.util.Optional<KafkaExporterConfig> |
createKafkaExporterConfig()
Create a
KafkaExporterConfig from these properties if enabled |
java.lang.String |
getBrokerId() |
java.util.Map<java.lang.String,java.lang.String> |
getLabels() |
java.util.function.Predicate<MetricKey> |
getMetricWhitelistFilter()
Get a predicate that filters metrics based on the whitelist configuration.
|
VolumeMetricsCollector.VolumeMetricsCollectorConfig |
getVolumeMetricsCollectorConfig() |
static void |
main(java.lang.String[] args) |
equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String PREFIX
public static final java.lang.String PREFIX_LABELS
public static final java.lang.String PREFIX_EXPORTER
public static final java.lang.String PREFIX_METRICS_COLLECTOR
public static final java.lang.String COLLECT_INTERVAL_CONFIG
public static final java.lang.Long DEFAULT_COLLECT_INTERVAL
public static final java.lang.String COLLECT_INTERVAL_DOC
public static final java.lang.String WHITELIST_CONFIG
public static final java.lang.String WHITELIST_DOC
public static final java.lang.String DEFAULT_WHITELIST
public static final java.util.List<java.lang.String> DEFAULT_BROKER_MONITORING_METRICS
public static final java.lang.String DEBUG_ENABLED
public static final java.lang.String DEBUG_ENABLED_DOC
public static final boolean DEFAULT_DEBUG_ENABLED
public static final java.lang.String EXPORTER_KAFKA_ENABLED_CONFIG
public static final java.lang.String EXPORTER_KAFKA_ENABLED_DOC
public static final boolean EXPORTER_KAFKA_ENABLED_DEFAULT
public static final java.lang.String EXPORTER_HTTP_ENABLED_CONFIG
public static final java.lang.String EXPORTER_HTTP_ENABLED_DOC
public static final boolean EXPORTER_HTTP_ENABLED_DEFAULT
public static final java.util.function.Predicate<MetricKey> ALWAYS_TRUE
public static final java.lang.String LEGACY_PREFIX
public ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals)
public static void main(java.lang.String[] args)
public java.util.Map<java.lang.String,java.lang.String> getLabels()
public java.lang.String getBrokerId()
public java.util.function.Predicate<MetricKey> getMetricWhitelistFilter()
public java.util.Optional<KafkaExporterConfig> createKafkaExporterConfig()
KafkaExporterConfig
from these properties if enabledpublic java.util.Optional<HttpExporterConfig> createHttpExporterConfig()
HttpExporterConfig
from these properties if enabledpublic VolumeMetricsCollector.VolumeMetricsCollectorConfig getVolumeMetricsCollectorConfig()