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 |
CONFIG_EVENTS_ENABLE_CONFIG |
static java.lang.Boolean |
CONFIG_EVENTS_ENABLE_DEFAULT |
static java.lang.String |
CONFIG_EVENTS_ENABLE_DOC |
static java.util.List<java.lang.String> |
CONFIG_EVENTS_INCLUDE |
static java.lang.String |
CONFIG_EVENTS_INCLUDE_CONFIG |
static java.lang.String |
CONFIG_EVENTS_INCLUDE_DEFAULT |
static java.lang.String |
CONFIG_EVENTS_INCLUDE_DOC |
static java.lang.String |
DEBUG_ENABLED |
static java.lang.String |
DEBUG_ENABLED_DOC |
static java.lang.Long |
DEFAULT_COLLECT_INTERVAL |
static boolean |
DEFAULT_DEBUG_ENABLED |
static java.lang.String |
DEFAULT_METRICS_INCLUDE |
static java.lang.String |
DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX |
static java.util.Map<java.lang.String,java.lang.Object> |
EXPORTER_CONFLUENT_DEFAULTS |
static java.lang.String |
EXPORTER_CONFLUENT_NAME |
static java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Object>> |
EXPORTER_DEFAULT_CONFIGS |
static java.util.Map<java.lang.String,java.lang.Object> |
EXPORTER_LOCAL_DEFAULTS |
static java.lang.String |
EXPORTER_LOCAL_METRICS_INCLUDE |
static java.lang.String |
EXPORTER_LOCAL_NAME |
static java.lang.String |
METRICS_INCLUDE_CONFIG |
static java.lang.String |
METRICS_INCLUDE_CONFIG_ALIAS |
static java.lang.String |
METRICS_INCLUDE_DOC |
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.util.Set<java.lang.String> |
RECONFIGURABLES |
static java.lang.String |
TELEMETRY_API_KEY
High level configs tied only to the default Confluent Cloud Http Exporter for simplified usage.
|
static java.lang.String |
TELEMETRY_API_KEY_DOC |
static java.lang.String |
TELEMETRY_API_SECRET |
static java.lang.String |
TELEMETRY_API_SECRET_DOC |
static java.lang.String |
TELEMETRY_ENABLED_CONFIG |
static boolean |
TELEMETRY_ENABLED_DEFAULT |
static java.lang.String |
TELEMETRY_ENABLED_DOC |
static java.lang.String |
TELEMETRY_PROXY_PASSWORD |
static java.lang.String |
TELEMETRY_PROXY_PASSWORD_DOC |
static java.lang.String |
TELEMETRY_PROXY_URL |
static java.lang.String |
TELEMETRY_PROXY_URL_DOC |
static java.lang.String |
TELEMETRY_PROXY_USERNAME |
static java.lang.String |
TELEMETRY_PROXY_USERNAME_DOC |
Constructor and Description |
---|
ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals) |
ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,ExporterConfig> |
allExporters() |
java.util.Map<java.lang.String,ExporterConfig> |
allExportersWithNames(java.util.Set<java.lang.String> names) |
java.util.Map<java.lang.String,HttpExporterConfig> |
allHttpExporters() |
java.util.function.Predicate<MetricKey> |
buildMetricsPredicate() |
static java.util.function.Predicate<MetricKey> |
buildMetricsPredicate(java.lang.String regexString) |
java.util.Map<java.lang.String,ExporterConfig> |
enabledExporters() |
static java.lang.String |
exporterPrefixForName(java.lang.String name) |
java.util.Map<java.lang.String,java.lang.String> |
getLabels() |
VolumeMetricsCollector.VolumeMetricsCollectorConfig |
getVolumeMetricsCollectorConfig() |
static java.lang.String |
joinIncludeRegexList(java.util.List<java.lang.String> includeRegexList) |
static void |
main(java.lang.String[] args) |
static java.util.Map<java.lang.String,?> |
reconcileConfigs(java.util.Map<java.lang.String,?> config) |
documentationOf, 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 METRICS_INCLUDE_CONFIG
public static final java.lang.String METRICS_INCLUDE_CONFIG_ALIAS
public static final java.lang.String DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX
public static final java.lang.String METRICS_INCLUDE_DOC
public static final java.lang.String DEFAULT_METRICS_INCLUDE
public static final java.lang.String CONFIG_EVENTS_ENABLE_CONFIG
public static final java.lang.String CONFIG_EVENTS_ENABLE_DOC
public static final java.lang.Boolean CONFIG_EVENTS_ENABLE_DEFAULT
public static final java.lang.String CONFIG_EVENTS_INCLUDE_CONFIG
public static final java.lang.String CONFIG_EVENTS_INCLUDE_DOC
public static final java.lang.String CONFIG_EVENTS_INCLUDE_DEFAULT
public static final java.util.List<java.lang.String> CONFIG_EVENTS_INCLUDE
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_LOCAL_NAME
public static final java.lang.String EXPORTER_LOCAL_METRICS_INCLUDE
public static final java.util.Map<java.lang.String,java.lang.Object> EXPORTER_LOCAL_DEFAULTS
public static final java.lang.String EXPORTER_CONFLUENT_NAME
public static final java.util.Map<java.lang.String,java.lang.Object> EXPORTER_CONFLUENT_DEFAULTS
public static final java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Object>> EXPORTER_DEFAULT_CONFIGS
public static final java.lang.String TELEMETRY_API_KEY
public static final java.lang.String TELEMETRY_API_KEY_DOC
public static final java.lang.String TELEMETRY_API_SECRET
public static final java.lang.String TELEMETRY_API_SECRET_DOC
public static final java.lang.String TELEMETRY_ENABLED_CONFIG
public static final java.lang.String TELEMETRY_ENABLED_DOC
public static final boolean TELEMETRY_ENABLED_DEFAULT
public static final java.lang.String TELEMETRY_PROXY_URL
public static final java.lang.String TELEMETRY_PROXY_URL_DOC
public static final java.lang.String TELEMETRY_PROXY_USERNAME
public static final java.lang.String TELEMETRY_PROXY_USERNAME_DOC
public static final java.lang.String TELEMETRY_PROXY_PASSWORD
public static final java.lang.String TELEMETRY_PROXY_PASSWORD_DOC
public static final java.util.Set<java.lang.String> RECONFIGURABLES
public static final java.util.function.Predicate<MetricKey> ALWAYS_TRUE
public ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals)
public ConfluentTelemetryConfig(java.util.Map<java.lang.String,?> originals, boolean doLog)
public static java.lang.String joinIncludeRegexList(java.util.List<java.lang.String> includeRegexList)
public static java.lang.String exporterPrefixForName(java.lang.String name)
public static void main(java.lang.String[] args)
public java.util.Map<java.lang.String,java.lang.String> getLabels()
public java.util.function.Predicate<MetricKey> buildMetricsPredicate()
public static java.util.function.Predicate<MetricKey> buildMetricsPredicate(java.lang.String regexString)
public VolumeMetricsCollector.VolumeMetricsCollectorConfig getVolumeMetricsCollectorConfig()
public static java.util.Map<java.lang.String,?> reconcileConfigs(java.util.Map<java.lang.String,?> config)
public java.util.Map<java.lang.String,ExporterConfig> allExporters()
public java.util.Map<java.lang.String,ExporterConfig> enabledExporters()
public java.util.Map<java.lang.String,ExporterConfig> allExportersWithNames(java.util.Set<java.lang.String> names)
public java.util.Map<java.lang.String,HttpExporterConfig> allHttpExporters()