Class ConfluentTelemetryConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.telemetry.ConfluentTelemetryConfig

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

Field Summary

Fields

Modifier and Type	Field	Description
static final Map<String,Object>	CLIENT_CONFLUENT_DEFAULTS
static final String	CLIENT_CONFLUENT_NAME
static final Map<String, Map<String,Object>>	CLIENT_DEFAULT_CONFIGS
static final String	CLUSTER_ID_CONFIG
static final String	CLUSTER_ID_DOC
static final String	COLLECT_INTERVAL_CONFIG
static final String	COLLECT_INTERVAL_DOC
static final String	CONFIG_EVENTS_ENABLE_CONFIG
static final Boolean	CONFIG_EVENTS_ENABLE_DEFAULT
static final String	CONFIG_EVENTS_ENABLE_DOC
static final List<String>	CONFIG_EVENTS_INCLUDE
static final String	CONFIG_EVENTS_INCLUDE_CONFIG
static final String	CONFIG_EVENTS_INCLUDE_DEFAULT
static final String	CONFIG_EVENTS_INCLUDE_DOC
static final String	CPU_METRIC
static final String	DEBUG_ENABLED
static final String	DEBUG_ENABLED_DOC
static final Set<String>	DEFAULT_ACTIVE_FILTER_SET
static final Long	DEFAULT_COLLECT_INTERVAL
static final boolean	DEFAULT_DEBUG_ENABLED
static final String	DEFAULT_METRICS_INCLUDE
static final int	DEFAULT_MIN_ISR
static final String	DEFAULT_NAMED_FILTER_NAME
static final Boolean	DEFAULT_SLO_COLLECTOR_ENABLED
static final String	DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX
static final Map<String,Object>	EXPORTER_C3PLUSPLUS_DEFAULTS
static final String	EXPORTER_C3PLUSPLUS_METRICS_INCLUDE
static final String	EXPORTER_C3PLUSPLUS_NAME
static final Map<String,Object>	EXPORTER_CONFLUENT_DEFAULTS
static final String	EXPORTER_CONFLUENT_NAME
static final Map<String, Map<String,Object>>	EXPORTER_DEFAULT_CONFIGS
static final Map<String,Object>	EXPORTER_LOCAL_DEFAULTS
static final String	EXPORTER_LOCAL_METRICS_INCLUDE
static final String	EXPORTER_LOCAL_NAME
static final String	EXPORTER_USM_NAME
static final String	METRICS_INCLUDE_CONFIG
static final String	METRICS_INCLUDE_DOC
static final String	PREFIX
static final String	PREFIX_EXPORTER
static final String	PREFIX_EXPORTER_CLIENT
static final String	PREFIX_LABELS
static final String	PREFIX_METRICS_COLLECTOR
static final String	PREFIX_REMOTE_CONFIG
static final Set<String>	RECONFIGURABLES
static final String	REMOTE_CONFIG_CONFLUENT
static final String	SLO_COLLECTOR_DOC
static final String	SLO_COLLECTOR_ENABLED
static final String	TELEMETRY_API_KEY	High level configs tied only to the default Confluent Cloud Http Exporter for simplified usage.
static final String	TELEMETRY_API_KEY_DOC
static final String	TELEMETRY_API_SECRET
static final String	TELEMETRY_API_SECRET_DOC
static final String	TELEMETRY_CONFLUENT_CLOUD_URL
static final String	TELEMETRY_ENABLED_CONFIG
static final boolean	TELEMETRY_ENABLED_DEFAULT
static final String	TELEMETRY_ENABLED_DOC
static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS
static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DEFAULT
static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DOC
static final String	TELEMETRY_HTTP_URL
static final String	TELEMETRY_HTTP_URL_DOC
static final String	TELEMETRY_PROXY_PASSWORD
static final String	TELEMETRY_PROXY_PASSWORD_DOC
static final String	TELEMETRY_PROXY_URL
static final String	TELEMETRY_PROXY_URL_DOC
static final String	TELEMETRY_PROXY_USERNAME
static final String	TELEMETRY_PROXY_USERNAME_DOC
static final String	USM_ADDITIONAL_CLIENT_METRICS_INCLUDE_REGEX
static final String	USM_CLIENT_TELEMETRY_METRICS_INCLUDE_REGEX
static final String	USM_CONSUMER_GROUP_METRICS_INCLUDE_REGEX
static final String	USM_HTTP_EXPORTER_METRICS_INCLUDE_REGEX
static final String	USM_REQUEST_TOTAL_TIME_METRICS_INCLUDE_REGEX

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
ConfluentTelemetryConfig(Map<String,?> originals)
ConfluentTelemetryConfig(Map<String,?> originals, boolean doLog)

Method Summary

Modifier and Type	Method	Description
void	addClientConfig(String clientName, Map<String,Object> rawConfig)
void	addExporterConfig(String exporterName, Map<String,Object> rawConfig)
Map<String, ExporterConfig>	allExporters()
Map<String, ExporterConfig>	allExportersWithNames(Set<String> names)
Map<String, HttpClientConfig>	allHttpClients()
Map<String, HttpExporterConfig>	allHttpExporters()
static String	clientPrefixForName(String name)
Map<String, ExporterConfig>	enabledExporters()
static String	exporterPrefixForName(String name)
Set<String>	getClientMetricsExcludeLabels()
FilterSetPredicate	getDefaultFilterSet()
Map<String,String>	getLabels()
Optional<RemoteConfigConfiguration>	getRemoteConfigConfiguration()
VolumeMetricsCollector.VolumeMetricsCollectorConfig	getVolumeMetricsCollectorConfig()
boolean	hasClientWithName(String clientName)
boolean	hasExporterWithName(String exporterName)
Boolean	isDebugEnabled()
static String	joinIncludeRegexList(List<String> includeRegexList)
static void	main(String[] args)
static Map<String,?>	reconcileConfigs(Map<String,?> config)
void	updateClientConfigs(String clientName, Map<String,?> configOverrides)
void	updateExporterConfigs(String exporterName, Map<String,?> configOverrides)

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

Field Details

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

PREFIX_LABELS

public static final String PREFIX_LABELS

See Also:

• Constant Field Values

PREFIX_EXPORTER

public static final String PREFIX_EXPORTER

See Also:

• Constant Field Values

PREFIX_EXPORTER_CLIENT

public static final String PREFIX_EXPORTER_CLIENT

See Also:

• Constant Field Values

PREFIX_METRICS_COLLECTOR

public static final String PREFIX_METRICS_COLLECTOR

See Also:

• Constant Field Values

CLUSTER_ID_CONFIG

public static final String CLUSTER_ID_CONFIG

See Also:

• Constant Field Values

CLUSTER_ID_DOC

public static final String CLUSTER_ID_DOC

See Also:

• Constant Field Values

COLLECT_INTERVAL_CONFIG

public static final String COLLECT_INTERVAL_CONFIG

See Also:

• Constant Field Values

DEFAULT_COLLECT_INTERVAL

public static final Long DEFAULT_COLLECT_INTERVAL

COLLECT_INTERVAL_DOC

public static final String COLLECT_INTERVAL_DOC

See Also:

• Constant Field Values

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS

public static final String TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS

See Also:

• Constant Field Values

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DOC

public static final String TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DOC

See Also:

• Constant Field Values

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DEFAULT

public static final String TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DEFAULT

See Also:

• Constant Field Values

METRICS_INCLUDE_CONFIG

public static final String METRICS_INCLUDE_CONFIG

See Also:

• Constant Field Values

SLO_COLLECTOR_ENABLED

public static final String SLO_COLLECTOR_ENABLED

See Also:

• Constant Field Values

DEFAULT_SLO_COLLECTOR_ENABLED

public static final Boolean DEFAULT_SLO_COLLECTOR_ENABLED

SLO_COLLECTOR_DOC

public static final String SLO_COLLECTOR_DOC

See Also:

• Constant Field Values

DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX

public static final String DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX

METRICS_INCLUDE_DOC

public static final String METRICS_INCLUDE_DOC

See Also:

• Constant Field Values

DEFAULT_METRICS_INCLUDE

public static final String DEFAULT_METRICS_INCLUDE

CONFIG_EVENTS_ENABLE_CONFIG

public static final String CONFIG_EVENTS_ENABLE_CONFIG

See Also:

• Constant Field Values

CONFIG_EVENTS_ENABLE_DOC

public static final String CONFIG_EVENTS_ENABLE_DOC

See Also:

• Constant Field Values

CONFIG_EVENTS_ENABLE_DEFAULT

public static final Boolean CONFIG_EVENTS_ENABLE_DEFAULT

CONFIG_EVENTS_INCLUDE_CONFIG

public static final String CONFIG_EVENTS_INCLUDE_CONFIG

See Also:

• Constant Field Values

CONFIG_EVENTS_INCLUDE_DOC

public static final String CONFIG_EVENTS_INCLUDE_DOC

See Also:

• Constant Field Values

CONFIG_EVENTS_INCLUDE_DEFAULT

public static final String CONFIG_EVENTS_INCLUDE_DEFAULT

CONFIG_EVENTS_INCLUDE

public static final List<String> CONFIG_EVENTS_INCLUDE

DEBUG_ENABLED

public static final String DEBUG_ENABLED

See Also:

• Constant Field Values

DEBUG_ENABLED_DOC

public static final String DEBUG_ENABLED_DOC

See Also:

• Constant Field Values

DEFAULT_DEBUG_ENABLED

public static final boolean DEFAULT_DEBUG_ENABLED

See Also:

• Constant Field Values

DEFAULT_NAMED_FILTER_NAME

public static final String DEFAULT_NAMED_FILTER_NAME

See Also:

• Constant Field Values

DEFAULT_ACTIVE_FILTER_SET

public static final Set<String> DEFAULT_ACTIVE_FILTER_SET

CPU_METRIC

public static final String CPU_METRIC

EXPORTER_LOCAL_NAME

public static final String EXPORTER_LOCAL_NAME

See Also:

• Constant Field Values

EXPORTER_LOCAL_METRICS_INCLUDE

public static final String EXPORTER_LOCAL_METRICS_INCLUDE

EXPORTER_LOCAL_DEFAULTS

public static final Map<String,Object> EXPORTER_LOCAL_DEFAULTS

EXPORTER_C3PLUSPLUS_NAME

public static final String EXPORTER_C3PLUSPLUS_NAME

See Also:

• Constant Field Values

EXPORTER_C3PLUSPLUS_METRICS_INCLUDE

public static final String EXPORTER_C3PLUSPLUS_METRICS_INCLUDE

See Also:

• Constant Field Values

EXPORTER_C3PLUSPLUS_DEFAULTS

public static final Map<String,Object> EXPORTER_C3PLUSPLUS_DEFAULTS

EXPORTER_USM_NAME

public static final String EXPORTER_USM_NAME

See Also:

• Constant Field Values

USM_CLIENT_TELEMETRY_METRICS_INCLUDE_REGEX

public static final String USM_CLIENT_TELEMETRY_METRICS_INCLUDE_REGEX

See Also:

• Constant Field Values

USM_REQUEST_TOTAL_TIME_METRICS_INCLUDE_REGEX

public static final String USM_REQUEST_TOTAL_TIME_METRICS_INCLUDE_REGEX

See Also:

• Constant Field Values

USM_CONSUMER_GROUP_METRICS_INCLUDE_REGEX

public static final String USM_CONSUMER_GROUP_METRICS_INCLUDE_REGEX

See Also:

• Constant Field Values

USM_ADDITIONAL_CLIENT_METRICS_INCLUDE_REGEX

public static final String USM_ADDITIONAL_CLIENT_METRICS_INCLUDE_REGEX

See Also:

• Constant Field Values

USM_HTTP_EXPORTER_METRICS_INCLUDE_REGEX

public static final String USM_HTTP_EXPORTER_METRICS_INCLUDE_REGEX

See Also:

• Constant Field Values

TELEMETRY_CONFLUENT_CLOUD_URL

public static final String TELEMETRY_CONFLUENT_CLOUD_URL

See Also:

• Constant Field Values

EXPORTER_CONFLUENT_NAME

public static final String EXPORTER_CONFLUENT_NAME

See Also:

• Constant Field Values

CLIENT_CONFLUENT_NAME

public static final String CLIENT_CONFLUENT_NAME

See Also:

• Constant Field Values

EXPORTER_CONFLUENT_DEFAULTS

public static final Map<String,Object> EXPORTER_CONFLUENT_DEFAULTS

CLIENT_CONFLUENT_DEFAULTS

public static final Map<String,Object> CLIENT_CONFLUENT_DEFAULTS

EXPORTER_DEFAULT_CONFIGS

public static final Map<String, Map<String,Object>> EXPORTER_DEFAULT_CONFIGS

CLIENT_DEFAULT_CONFIGS

public static final Map<String, Map<String,Object>> CLIENT_DEFAULT_CONFIGS

PREFIX_REMOTE_CONFIG

public static final String PREFIX_REMOTE_CONFIG

See Also:

• Constant Field Values

REMOTE_CONFIG_CONFLUENT

public static final String REMOTE_CONFIG_CONFLUENT

See Also:

• Constant Field Values

TELEMETRY_API_KEY

public static final String TELEMETRY_API_KEY

High level configs tied only to the default Confluent Cloud Http Exporter for simplified usage.

See Also:

• Constant Field Values

TELEMETRY_API_KEY_DOC

public static final String TELEMETRY_API_KEY_DOC

See Also:

• Constant Field Values

TELEMETRY_API_SECRET

public static final String TELEMETRY_API_SECRET

See Also:

• Constant Field Values

TELEMETRY_API_SECRET_DOC

public static final String TELEMETRY_API_SECRET_DOC

See Also:

• Constant Field Values

TELEMETRY_HTTP_URL

public static final String TELEMETRY_HTTP_URL

See Also:

• Constant Field Values

TELEMETRY_HTTP_URL_DOC

public static final String TELEMETRY_HTTP_URL_DOC

See Also:

• Constant Field Values

TELEMETRY_ENABLED_CONFIG

public static final String TELEMETRY_ENABLED_CONFIG

See Also:

• Constant Field Values

TELEMETRY_ENABLED_DOC

public static final String TELEMETRY_ENABLED_DOC

See Also:

• Constant Field Values

TELEMETRY_ENABLED_DEFAULT

public static final boolean TELEMETRY_ENABLED_DEFAULT

See Also:

• Constant Field Values

TELEMETRY_PROXY_URL

public static final String TELEMETRY_PROXY_URL

See Also:

• Constant Field Values

TELEMETRY_PROXY_URL_DOC

public static final String TELEMETRY_PROXY_URL_DOC

See Also:

• Constant Field Values

TELEMETRY_PROXY_USERNAME

public static final String TELEMETRY_PROXY_USERNAME

See Also:

• Constant Field Values

TELEMETRY_PROXY_USERNAME_DOC

public static final String TELEMETRY_PROXY_USERNAME_DOC

See Also:

• Constant Field Values

TELEMETRY_PROXY_PASSWORD

public static final String TELEMETRY_PROXY_PASSWORD

See Also:

• Constant Field Values

TELEMETRY_PROXY_PASSWORD_DOC

public static final String TELEMETRY_PROXY_PASSWORD_DOC

See Also:

• Constant Field Values

RECONFIGURABLES

public static final Set<String> RECONFIGURABLES

DEFAULT_MIN_ISR

public static final int DEFAULT_MIN_ISR

See Also:

• Constant Field Values

Constructor Details

ConfluentTelemetryConfig

public ConfluentTelemetryConfig(Map<String,?> originals)

ConfluentTelemetryConfig

public ConfluentTelemetryConfig(Map<String,?> originals,
 boolean doLog)

Method Details

joinIncludeRegexList

public static String joinIncludeRegexList(List<String> includeRegexList)

exporterPrefixForName

public static String exporterPrefixForName(String name)

clientPrefixForName

public static String clientPrefixForName(String name)

getClientMetricsExcludeLabels

public Set<String> getClientMetricsExcludeLabels()

main

public static void main(String[] args)

getLabels

public Map<String,String> getLabels()

isDebugEnabled

public Boolean isDebugEnabled()

getDefaultFilterSet

public FilterSetPredicate getDefaultFilterSet()

getVolumeMetricsCollectorConfig

public VolumeMetricsCollector.VolumeMetricsCollectorConfig getVolumeMetricsCollectorConfig()

getRemoteConfigConfiguration

public Optional<RemoteConfigConfiguration> getRemoteConfigConfiguration()

reconcileConfigs

public static Map<String,?> reconcileConfigs(Map<String,?> config)

updateClientConfigs

public void updateClientConfigs(String clientName,
 Map<String,?> configOverrides)

updateExporterConfigs

public void updateExporterConfigs(String exporterName,
 Map<String,?> configOverrides)

addClientConfig

public void addClientConfig(String clientName,
 Map<String,Object> rawConfig)

addExporterConfig

public void addExporterConfig(String exporterName,
 Map<String,Object> rawConfig)

allExporters

public Map<String, ExporterConfig> allExporters()

enabledExporters

public Map<String, ExporterConfig> enabledExporters()

allExportersWithNames

public Map<String, ExporterConfig> allExportersWithNames(Set<String> names)

allHttpExporters

public Map<String, HttpExporterConfig> allHttpExporters()

allHttpClients

public Map<String, HttpClientConfig> allHttpClients()

hasExporterWithName

public boolean hasExporterWithName(String exporterName)

hasClientWithName

public boolean hasClientWithName(String clientName)