Constant Field Values

Contents

• io.confluent.*

io.confluent.*

io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

Modifier and Type	Constant Field	Value
public static final String	BOOTSTRAP_SERVERS_CONFIG	"confluent.metrics.reporter.bootstrap.servers"
public static final String	BOOTSTRAP_SERVERS_DOC	"Bootstrap servers for the Kafka cluster metrics will be published to. The metrics cluster may be different from the cluster(s) whose metrics are being collected. Several production Kafka clusters can publish to a single metrics cluster, for example."
public static final int	DEFAULT_MIN_ISR	1
public static final String	DEFAULT_TOPIC_CONFIG	"_confluent-metrics"
public static final boolean	DEFAULT_TOPIC_CREATE_CONFIG	true
public static final int	DEFAULT_TOPIC_MAX_MESSAGE_BYTES_CONFIG	10485760
public static final int	DEFAULT_TOPIC_PARTITIONS_CONFIG	12
public static final int	DEFAULT_TOPIC_REPLICAS_CONFIG	3
public static final long	DEFAULT_TOPIC_RETENTION_BYTES_CONFIG	-1L
public static final long	DEFAULT_VOLUME_METRICS_REFRESH_PERIOD	15000L
public static final String	METRICS_INCLUDE_CONFIG	"confluent.metrics.reporter.include"
public static final String	METRICS_INCLUDE_DOC	"Regex matching the yammer metric mbean name or Kafka metric name to be published to the metrics topic.\n\nBy default this includes all the metrics required by Confluent Control Center and Confluent Auto Data Balancer. This should typically never be modified unless requested by Confluent."
public static final String	METRICS_REPORTER_PREFIX	"confluent.metrics.reporter."
public static final String	PUBLISH_PERIOD_CONFIG	"confluent.metrics.reporter.publish.ms"
public static final String	PUBLISH_PERIOD_DOC	"The metrics reporter will publish new metrics to the metrics topic in intervals defined by this setting. This means that control center system health data lags by this duration, or that rebalancer may compute a plan based on broker data that is stale by this duration. The default is a reasonable value for production environments and it typically does not need to be changed."
public static final String	TOPIC_CONFIG	"confluent.metrics.reporter.topic"
public static final String	TOPIC_CREATE_CONFIG	"confluent.metrics.reporter.topic.create"
public static final String	TOPIC_CREATE_DOC	"Create the metrics topic if it does not exist."
public static final String	TOPIC_DOC	"Topic on which metrics data will be written."
public static final String	TOPIC_MAX_MESSAGE_BYTES_CONFIG	"confluent.metrics.reporter.topic.max.message.bytes"
public static final String	TOPIC_MAX_MESSAGE_BYTES_DOC	"Maximum message size for the metrics topic."
public static final String	TOPIC_PARTITIONS_CONFIG	"confluent.metrics.reporter.topic.partitions"
public static final String	TOPIC_PARTITIONS_DOC	"Number of partitions in the metrics topic."
public static final String	TOPIC_REPLICAS_CONFIG	"confluent.metrics.reporter.topic.replicas"
public static final String	TOPIC_REPLICAS_DOC	"Number of replicas in the metric topic. It must not be higher than the number of brokers in the Kafka cluster."
public static final String	TOPIC_RETENTION_BYTES_CONFIG	"confluent.metrics.reporter.topic.retention.bytes"
public static final String	TOPIC_RETENTION_BYTES_DOC	"Retention bytes for the metrics topic."
public static final String	TOPIC_RETENTION_MS_CONFIG	"confluent.metrics.reporter.topic.retention.ms"
public static final String	TOPIC_RETENTION_MS_DOC	"Retention time for the metrics topic."
public static final String	TOPIC_ROLL_MS_CONFIG	"confluent.metrics.reporter.topic.roll.ms"
public static final String	TOPIC_ROLL_MS_DOC	"Log rolling time for the metrics topic."
public static final String	VOLUME_METRICS_REFRESH_PERIOD_DOC	"The minimum interval at which to fetch new volume metrics."
public static final String	VOLUME_METRICS_REFRESH_PERIOD_MS	"confluent.metrics.reporter.volume.metrics.refresh.ms"

io.confluent.metrics.reporter.Utils

Modifier and Type	Constant Field	Value
public static final String	EMPTY_STRING	""

io.confluent.telemetry.ConfluentTelemetryConfig

Modifier and Type	Constant Field	Value
public static final String	CLIENT_CONFLUENT_NAME	"_confluentClient"
public static final String	CLUSTER_ID_CONFIG	"confluent.telemetry.cluster.id"
public static final String	CLUSTER_ID_DOC	"The ID of the physical cluster the Telemetry Reporter is configured for"
public static final String	COLLECT_INTERVAL_CONFIG	"confluent.telemetry.metrics.collector.interval.ms"
public static final String	COLLECT_INTERVAL_DOC	"The metrics reporter will collect new metrics from the system in intervals defined by this setting. This means that control center system health data lags by this duration, or that rebalancer may compute a plan based on broker data that is stale by this duration. The default is a reasonable value for production environments and it typically does not need to be changed."
public static final String	CONFIG_EVENTS_ENABLE_CONFIG	"confluent.telemetry.events.enable"
public static final String	CONFIG_EVENTS_ENABLE_DOC	"Enable config events collection.Enabled by default for v7.0."
public static final String	CONFIG_EVENTS_INCLUDE_CONFIG	"confluent.telemetry.events.collector.include"
public static final String	CONFIG_EVENTS_INCLUDE_DOC	"Regex matching the config names to be published to telemetry collector.This should typically never be modified unless requested by Confluent."
public static final String	DEBUG_ENABLED	"confluent.telemetry.debug.enabled"
public static final String	DEBUG_ENABLED_DOC	"Enable debug metadata for metrics collection"
public static final boolean	DEFAULT_DEBUG_ENABLED	false
public static final int	DEFAULT_MIN_ISR	1
public static final String	DEFAULT_NAMED_FILTER_NAME	"_default"
public static final String	EXPORTER_C3PLUSPLUS_METRICS_INCLUDE	"(io.confluent.kafka.server.request.(?!.*delta).*|io.confluent.kafka.server.server.broker.state|io.confluent.kafka.server.replica.manager.leader.count|io.confluent.kafka.server.request.queue.size|io.confluent.kafka.server.broker.topic.failed.produce.requests.rate.1_min|io.confluent.kafka.server.tier.archiver.total.lag|io.confluent.kafka.server.request.total.time.ms.p99|io.confluent.kafka.server.broker.topic.failed.fetch.requests.rate.1_min|io.confluent.kafka.server.log.total.size|io.confluent.kafka.server.broker.topic.total.fetch.requests.rate.1_min|io.confluent.kafka.server.partition.caught.up.replicas.count|io.confluent.kafka.server.partition.observer.replicas.count|io.confluent.kafka.server.tier.tasks.num.partitions.in.error|io.confluent.kafka.server.broker.topic.bytes.out.rate.1_min|io.confluent.kafka.server.request.total.time.ms.p95|io.confluent.kafka.server.controller.active.controller.count|io.confluent.kafka.server.session.expire.listener.zookeeper.disconnects.total|io.confluent.kafka.server.request.total.time.ms.p999|io.confluent.kafka.server.controller.active.broker.count|io.confluent.kafka.server.request.handler.pool.request.handler.avg.idle.percent.rate.1_min|io.confluent.kafka.server.session.expire.listener.zookeeper.disconnects.rate.1_min|io.confluent.kafka.server.controller.unclean.leader.elections.rate.1_min|io.confluent.kafka.server.replica.manager.partition.count|io.confluent.kafka.server.controller.unclean.leader.elections.total|io.confluent.kafka.server.partition.replicas.count|io.confluent.kafka.server.broker.topic.total.produce.requests.rate.1_min|io.confluent.kafka.server.controller.offline.partitions.count|io.confluent.kafka.server.socket.server.network.processor.avg.idle.percent|io.confluent.kafka.server.partition.under.replicated|io.confluent.kafka.server.log.log.start.offset|io.confluent.kafka.server.log.tier.size|io.confluent.kafka.server.log.size|io.confluent.kafka.server.tier.fetcher.bytes.fetched.total|io.confluent.kafka.server.request.total.time.ms.p50|io.confluent.kafka.server.tenant.consumer.lag.offsets|io.confluent.kafka.server.session.expire.listener.zookeeper.expires.rate.1_min|io.confluent.kafka.server.log.log.end.offset|io.confluent.kafka.server.log.num.log.segments|io.confluent.kafka.server.broker.topic.bytes.in.rate.1_min|io.confluent.kafka.server.partition.under.min.isr|io.confluent.kafka.server.partition.in.sync.replicas.count|io.confluent.telemetry.http.exporter.batches.dropped|io.confluent.telemetry.http.exporter.items.total|io.confluent.telemetry.http.exporter.items.succeeded|io.confluent.telemetry.http.exporter.send.time.total.millis|io.confluent.kafka.server.controller.leader.election.rate.(?!.*delta).*|io.confluent.telemetry.http.exporter.batches.failed)"
public static final String	EXPORTER_C3PLUSPLUS_NAME	"_c3"
public static final String	EXPORTER_CONFLUENT_NAME	"_confluent"
public static final String	EXPORTER_LOCAL_NAME	"_local"
public static final String	METRICS_INCLUDE_CONFIG	"confluent.telemetry.metrics.collector.include"
public static final String	METRICS_INCLUDE_DOC	"Regex matching the converted (snake_case) metric name to be published to the metrics topic.\n\nBy default this includes all the metrics required by Proactive Support and Self-balancing Clusters. This should typically never be modified unless requested by Confluent."
public static final String	PREFIX	"confluent.telemetry."
public static final String	PREFIX_EXPORTER	"confluent.telemetry.exporter."
public static final String	PREFIX_EXPORTER_CLIENT	"confluent.telemetry.client."
public static final String	PREFIX_LABELS	"confluent.telemetry.labels."
public static final String	PREFIX_METRICS_COLLECTOR	"confluent.telemetry.metrics.collector."
public static final String	PREFIX_REMOTE_CONFIG	"confluent.telemetry.remoteconfig."
public static final String	REMOTE_CONFIG_CONFLUENT	"_confluent."
public static final String	SLO_COLLECTOR_DOC	"Enable SLO metric collector"
public static final String	SLO_COLLECTOR_ENABLED	"confluent.telemetry.metrics.collector.slo.enabled"
public static final String	TELEMETRY_API_KEY	"confluent.telemetry.api.key"
public static final String	TELEMETRY_API_KEY_DOC	"The API key used to authenticate HTTP requests with the Confluent telemetry server"
public static final String	TELEMETRY_API_SECRET	"confluent.telemetry.api.secret"
public static final String	TELEMETRY_API_SECRET_DOC	"The API secret used to authenticate HTTP requests with the Confluent Telemetry server"
public static final String	TELEMETRY_CONFLUENT_CLOUD_URL	"https://collector.telemetry.confluent.cloud"
public static final String	TELEMETRY_ENABLED_CONFIG	"confluent.telemetry.enabled"
public static final boolean	TELEMETRY_ENABLED_DEFAULT	false
public static final String	TELEMETRY_ENABLED_DOC	"True if telemetry data can to be reported to Confluent Cloud"
public static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS	"confluent.telemetry.external.client.metrics.exclude.labels"
public static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DEFAULT	""
public static final String	TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DOC	"Comma-separated list of labels/attributes to exclude from client metrics."
public static final String	TELEMETRY_PROXY_PASSWORD	"confluent.telemetry.proxy.password"
public static final String	TELEMETRY_PROXY_PASSWORD_DOC	"The password credential for the forward HTTP proxy to send Telemetry data to Confluent Cloud"
public static final String	TELEMETRY_PROXY_URL	"confluent.telemetry.proxy.url"
public static final String	TELEMETRY_PROXY_URL_DOC	"The URL for an explicit (i.e. not transparent) forward HTTP proxy to send Telemetry data to Confluent Cloud"
public static final String	TELEMETRY_PROXY_USERNAME	"confluent.telemetry.proxy.username"
public static final String	TELEMETRY_PROXY_USERNAME_DOC	"The username credential for the forward HTTP proxy to send Telemetry data to Confluent Cloud"

io.confluent.telemetry.HostResourceLabelProvider

Modifier and Type	Constant Field	Value
public static final String	KEY_HOSTNAME	"host.hostname"
public static final String	NAMESPACE	"host"

io.confluent.telemetry.JavaRuntimeResourceLabelProvider

Modifier and Type	Constant Field	Value
public static final String	KEY_VERSION	"java.version"
public static final String	NAMESPACE	"java"

io.confluent.telemetry.PredicateUtils

Modifier and Type	Constant Field	Value
public static final long	MATCHER_CACHE_MAX_SIZE	5000L

io.confluent.telemetry.collector.ConfluentMetricNamingConvention

Modifier and Type	Constant Field	Value
public static final String	KAFKA_METRICS_LIB	"kafka"
public static final String	YAMMER_METRICS_LIB	"yammer"

io.confluent.telemetry.collector.JvmMetricsCollector

Modifier and Type	Constant Field	Value
public static final String	SYSTEM_DOMAIN	"io.confluent.system"

io.confluent.telemetry.collector.MetricsCollector

Modifier and Type	Constant Field	Value
public static final String	LABEL_LIBRARY	"library"
public static final String	LABEL_ORIGINAL	"metric_name_original"
public static final String	LIBRARY_NONE	"none"

io.confluent.telemetry.collector.VolumeMetricsCollector

Modifier and Type	Constant Field	Value
public static final String	VOLUME_LABEL	"volume"

io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

Modifier and Type	Constant Field	Value
public static final long	DEFAULT_VOLUME_METRICS_UPDATE_PERIOD	15000L
public static final String	PREFIX	"confluent.telemetry.metrics.collector.volume."
public static final String	VOLUME_METRICS_UPDATE_PERIOD_DOC	"The minimum interval at which to fetch new volume metrics."
public static final String	VOLUME_METRICS_UPDATE_PERIOD_MS	"confluent.telemetry.metrics.collector.volume.update.ms"

io.confluent.telemetry.config.remote.RemoteConfigConfiguration

Modifier and Type	Constant Field	Value
public static final boolean	DEFAULT_ENABLED	false
public static final String	ENABLED_CONFIG	"enabled"
public static final String	ENABLED_CONFIG_DOC	"Boolean value. True if Telemetry Reportershould be remote configurable, false otherwise."

io.confluent.telemetry.config.remote.file.FileRemoteConfigConfiguration

Modifier and Type	Constant Field	Value
public static final String	PATH_CONFIG	"path"
public static final String	PATH_DOC	"Path to the configuration file"

io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

Modifier and Type	Constant Field	Value
public static final String	V1_CONFIGURATION_ENDPOINT	"/v1/config"

io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RETRY_ATTEMPTS	5
public static final double	DEFAULT_RETRY_BACKOFF_MULTIPLIER	2.0
public static final long	DEFAULT_RETRY_INITIAL_DELAY_MS	1000L
public static final long	DEFAULT_RETRY_MAX_DELAY_MS	30000L
public static final String	MAX_RETRY_ATTEMPTS_CONFIG	"max.retry.attempts"
public static final String	MAX_RETRY_ATTEMPTS_DOC	"The maximum number of retry attempts when requesting remote configuration fails with a retryable error. A value of 0 disables retries. The default value provides reasonable resilience against transient network issues."
public static final String	REFRESH_INTERVAL_MS_CONFIG	"refresh.interval.ms"
public static final String	REFRESH_INTERVAL_MS_DOC	"The configured remote configuration source will poll its source for a remote configuration for the Telemetry Reporter in intervals defined by this setting. The default is a reasonable value for production environments and it typically does not need to be changed."
public static final String	RETRY_BACKOFF_MULTIPLIER_CONFIG	"retry.backoff.multiplier"
public static final String	RETRY_BACKOFF_MULTIPLIER_DOC	"The multiplier applied to the retry delay for exponential backoff when requesting remote configuration fails with a retryable error. Each retry attempt will wait (previous_delay * multiplier) milliseconds, up to the maximum delay."
public static final String	RETRY_INITIAL_DELAY_MS_CONFIG	"retry.initial.delay.ms"
public static final String	RETRY_INITIAL_DELAY_MS_DOC	"The initial delay in milliseconds before the first retry attempt when requesting remote configuration fails with a retryable error. This delay will be increased exponentially for subsequent retry attempts."
public static final String	RETRY_MAX_DELAY_MS_CONFIG	"retry.max.delay.ms"
public static final String	RETRY_MAX_DELAY_MS_DOC	"The maximum delay in milliseconds between retry attempts when requesting remote configuration fails with a retryable error. This prevents exponential backoff from growing too large."

io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

Modifier and Type	Constant Field	Value
public static final String	CONFIG_MAP_NAME_CONFIG	"configmap.name"
public static final String	CONFIG_MAP_NAME_DOC	"The name of the Kubernetes Secret/ConfigMap to watch for changes to remotely configure if the override cluster named Secret/ConfigMap is not present"
public static final String	CONNECT_TIMEOUT_MS_CONFIG	"connect.timeout.ms"
public static final String	CONNECT_TIMEOUT_MS_DOC	"The timeout value, in milliseconds, to be used when opening a connection to the k8s resource."
public static final String	DEFAULT_NAMESPACE	"telemetry-config"
public static final String	NAMESPACE_CONFIG	"namespace"
public static final String	NAMESPACE_DOC	"The configured KubernetesRemoteConfiguration will watch for Secret/ConfigMap changes in this configured namespace"
public static final String	READ_TIMEOUT_MS_CONFIG	"read.timeout.ms"
public static final String	READ_TIMEOUT_MS_DOC	"The timeout value, in milliseconds, to be used when reading from an input stream when a connection to the k8s resource is established."

io.confluent.telemetry.exporter.ClientConfig

Modifier and Type	Constant Field	Value
public static final String	TYPE_CONFIG	"type"

io.confluent.telemetry.exporter.ExporterConfig

Modifier and Type	Constant Field	Value
public static final String	CLIENT_NAME_CONFIG	"client"
public static final String	CLIENT_NAME_CONFIG_DEFAULT	""
public static final String	CLIENT_NAME_CONFIG_DOC	"The name of the configured client to use for the exporter"
public static final String	ENABLED_CONFIG	"enabled"
public static final String	ENABLED_CONFIG_DOC	"Boolean value. True if exporter should be enabled, false otherwise. This is a mandatory field that has to be set for every exporter."
public static final String	EVENTS_ENABLED_CONFIG	"events.enabled"
public static final boolean	EVENTS_ENABLED_CONFIG_DEFAULT	true
public static final String	EVENTS_ENABLED_CONFIG_DOC	"Boolean value. True if telemetry events should be reported."
public static final String	METRICS_ENABLED_CONFIG	"metrics.enabled"
public static final boolean	METRICS_ENABLED_CONFIG_DEFAULT	true
public static final String	METRICS_ENABLED_CONFIG_DOC	"Boolean value. True if telemetry metrics should be reported."
public static final String	METRICS_INCLUDE_CONFIG	"metrics.include"
public static final String	METRICS_INCLUDE_CONFIG_DOC	"Regex matching the converted (snake_case) metric name to be published from this particular exporter.\n\nBy default this includes all the metrics required by Proactive Support and Self-balancing Clusters. This should typically never be modified unless requested by Confluent."
public static final String	NAMED_CLIENT_CONFIGURED_DOC_WARNING	" However, if a named exporter client is configured, this value should not be set"
public static final String	REMOTE_CONFIGURABLE_CONFIG	"remote.configurable"
public static final boolean	REMOTE_CONFIGURABLE_CONFIG_DEFAULT	true
public static final String	REMOTE_CONFIGURABLE_CONFIG_DOC	"Boolean value. True if the exporter should be remotely configurable."
public static final String	TYPE_CONFIG	"type"

io.confluent.telemetry.exporter.http.HttpClientConfig

Modifier and Type	Constant Field	Value
public static final String	API_KEY	"api.key"
public static final String	API_KEY_DOC	"The API key used to authenticate the requests made by HttpExporter."
public static final String	API_SECRET	"api.secret"
public static final String	API_SECRET_DOC	"The API secret used to authenticate requests made by HttpExporter."
public static final String	BUFFER_MAX_BATCH_DURATION_MS	"buffer.batch.duration.max.ms"
public static final String	BUFFER_MAX_BATCH_DURATION_MS_DOC	"The maximum duration (in millis) to buffer items before sending them upstream."
public static final String	BUFFER_MAX_BATCH_SIZE	"buffer.batch.items.max"
public static final String	BUFFER_MAX_BATCH_SIZE_DOC	"The maximum number of items to buffer into a batch before sending them upstream."
public static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS	"buffer.inflight.submissions.max"
public static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC	"The maximum number of in-flight calls to the HTTP service."
public static final String	BUFFER_MAX_PENDING_BATCHES	"buffer.pending.batches.max"
public static final String	BUFFER_MAX_PENDING_BATCHES_DOC	"The maximum number of pending batches. If more than this number of batches are pending(i.e. there is backpressure) then the oldest batches will be dropped."
public static final String	CLIENT_BASE_URL	"client.base.url"
public static final String	CLIENT_BASE_URL_DOC	"The base URL for the telemetry receiver (i.e. https://host:port)."
public static final String	CLIENT_COMPRESSION	"client.compression"
public static final String	CLIENT_COMPRESSION_DOC	"HTTP Compression algorithm to use. Either gzip, lz4, or zstd."
public static final String	CLIENT_CONNECT_TIMEOUT_MS	"client.connect.timeout.ms"
public static final String	CLIENT_CONNECT_TIMEOUT_MS_DOC	"The connect timeout in milliseconds."
public static final String	CLIENT_MAX_ATTEMPTS	"client.attempts.max"
public static final String	CLIENT_MAX_ATTEMPTS_DOC	"The maximum number of delivery attempts."
public static final String	CLIENT_METRICS_PATH	"client.metrics.path.override"
public static final String	CLIENT_METRICS_PATH_DEFAULT	"/v1/metrics"
public static final String	CLIENT_METRICS_PATH_DOC	"The URL path to post metrics to for metrics (i.e. /v1/metrics_override)."
public static final String	CLIENT_PORT	"client.port"
public static final int	CLIENT_PORT_DEFAULT	14318
public static final String	CLIENT_PORT_DOC	"OTel Collector HTTP port to send metrics to."
public static final String	CLIENT_REQUEST_TIMEOUT_MS	"client.request.timeout.ms"
public static final String	CLIENT_REQUEST_TIMEOUT_MS_DOCS	"The request timeout in milliseconds."
public static final String	CLIENT_RETRY_DELAY_SEC	"client.retry.delay.seconds"
public static final String	CLIENT_RETRY_DELAY_SEC_DOC	"The delay, in seconds, between retry attempts."
public static final String	PREFIX_API	"api."
public static final String	PREFIX_BUFFER	"buffer."
public static final String	PREFIX_CLIENT	"client."
public static final String	PREFIX_PROXY	"proxy."
public static final String	PROXY_PASSWORD	"proxy.password"
public static final String	PROXY_PASSWORD_DOC	"The password credential for the forward HTTP proxy."
public static final String	PROXY_URL	"proxy.url"
public static final String	PROXY_URL_DOC	"The URL for an explicit (i.e. not transparent) forward HTTP proxy."
public static final String	PROXY_USERNAME	"proxy.username"
public static final String	PROXY_USERNAME_DOC	"The username credential for the forward HTTP proxy."

io.confluent.telemetry.exporter.http.HttpExporter

Modifier and Type	Constant Field	Value
public static final String	SELF_METRICS_GROUP	"HttpExporter"

io.confluent.telemetry.exporter.http.HttpExporterConfig

Modifier and Type	Constant Field	Value
public static final String	API_KEY	"api.key"
public static final String	API_KEY_DOC	"The API key used to authenticate the requests made by HttpExporter. However, if a named exporter client is configured, this value should not be set"
public static final String	API_SECRET	"api.secret"
public static final String	API_SECRET_DOC	"The API secret used to authenticate requests made by HttpExporter. However, if a named exporter client is configured, this value should not be set"
public static final String	BUFFER_MAX_BATCH_DURATION_MS	"buffer.batch.duration.max.ms"
public static final String	BUFFER_MAX_BATCH_DURATION_MS_DOC	"The maximum duration (in millis) to buffer items before sending them upstream. However, if a named exporter client is configured, this value should not be set"
public static final String	BUFFER_MAX_BATCH_SIZE	"buffer.batch.items.max"
public static final String	BUFFER_MAX_BATCH_SIZE_DOC	"The maximum number of items to buffer into a batch before sending them upstream. However, if a named exporter client is configured, this value should not be set"
public static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS	"buffer.inflight.submissions.max"
public static final String	BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC	"The maximum number of in-flight calls to the HTTP service. However, if a named exporter client is configured, this value should not be set"
public static final String	BUFFER_MAX_PENDING_BATCHES	"buffer.pending.batches.max"
public static final String	BUFFER_MAX_PENDING_BATCHES_DOC	"The maximum number of pending batches. If more than this number of batches are pending(i.e. there is backpressure) then the oldest batches will be dropped. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_BASE_URL	"client.base.url"
public static final String	CLIENT_BASE_URL_DOC	"The base URL for the telemetry receiver (i.e. https://host:port). However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_COMPRESSION	"client.compression"
public static final String	CLIENT_COMPRESSION_DOC	"HTTP Compression algorithm to use. Either gzip, lz4, or zstd. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_CONNECT_TIMEOUT_MS	"client.connect.timeout.ms"
public static final String	CLIENT_CONNECT_TIMEOUT_MS_DOC	"The connect timeout in milliseconds. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_MAX_ATTEMPTS	"client.attempts.max"
public static final String	CLIENT_MAX_ATTEMPTS_DOC	"The maximum number of delivery attempts. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_METRICS_PATH	"client.metrics.path.override"
public static final String	CLIENT_METRICS_PATH_DEFAULT	"/v1/metrics"
public static final String	CLIENT_METRICS_PATH_DOC	"The URL path to post metrics to for metrics (i.e. /v1/metrics_override). However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_PORT	"client.port"
public static final int	CLIENT_PORT_DEFAULT	14318
public static final String	CLIENT_PORT_DOC	"OTel Collector HTTP port to send metrics to. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_REQUEST_TIMEOUT_MS	"client.request.timeout.ms"
public static final String	CLIENT_REQUEST_TIMEOUT_MS_DOCS	"The request timeout in milliseconds. However, if a named exporter client is configured, this value should not be set"
public static final String	CLIENT_RETRY_DELAY_SEC	"client.retry.delay.seconds"
public static final String	CLIENT_RETRY_DELAY_SEC_DOC	"The delay, in seconds, between retry attempts. However, if a named exporter client is configured, this value should not be set"
public static final String	CONNECTION_SSL_CONFIG_PREFIX	"https."
public static final String	PROXY_PASSWORD	"proxy.password"
public static final String	PROXY_PASSWORD_DOC	"The password credential for the forward HTTP proxy. However, if a named exporter client is configured, this value should not be set"
public static final String	PROXY_URL	"proxy.url"
public static final String	PROXY_URL_DOC	"The URL for an explicit (i.e. not transparent) forward HTTP proxy. However, if a named exporter client is configured, this value should not be set"
public static final String	PROXY_USERNAME	"proxy.username"
public static final String	PROXY_USERNAME_DOC	"The username credential for the forward HTTP proxy. However, if a named exporter client is configured, this value should not be set"

io.confluent.telemetry.exporter.kafka.KafkaExporter

Modifier and Type	Constant Field	Value
public static final String	VERSION_HEADER_KEY	"v"

io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

Modifier and Type	Constant Field	Value
public static final String	BOOTSTRAP_SERVERS_CONFIG	"producer.bootstrap.servers"
public static final String	BOOTSTRAP_SERVERS_DEFAULT	""
public static final String	BOOTSTRAP_SERVERS_DOC	"Bootstrap servers for the Kafka cluster telemetry will be published to. The target cluster may be different from the cluster(s) whose telemetry is being collected. Several production Kafka clusters can publish to a single target Kafka cluster, for example. However, if a named exporter client is configured, this value should not be set"
public static final boolean	DEFAULT_TOPIC_CREATE	true
public static final int	DEFAULT_TOPIC_MAX_MESSAGE_BYTES	10485760
public static final String	DEFAULT_TOPIC_NAME	"_confluent-telemetry-metrics"
public static final int	DEFAULT_TOPIC_PARTITIONS	12
public static final int	DEFAULT_TOPIC_REPLICAS	3
public static final long	DEFAULT_TOPIC_RETENTION_BYTES	-1L
public static final String	PREFIX_PRODUCER	"producer."
public static final String	PREFIX_TOPIC	"topic."
public static final String	TOPIC_CREATE_CONFIG	"topic.create"
public static final String	TOPIC_CREATE_DOC	"Create the metrics topic if it does not exist."
public static final String	TOPIC_MAX_MESSAGE_BYTES_CONFIG	"topic.max.message.bytes"
public static final String	TOPIC_MAX_MESSAGE_BYTES_DOC	"Maximum message size for the metrics topic."
public static final String	TOPIC_NAME_CONFIG	"topic.name"
public static final String	TOPIC_NAME_DOC	"Topic to which metrics data will be written."
public static final String	TOPIC_PARTITIONS_CONFIG	"topic.partitions"
public static final String	TOPIC_PARTITIONS_DOC	"Number of partitions in the metrics topic."
public static final String	TOPIC_REPLICAS_CONFIG	"topic.replicas"
public static final String	TOPIC_REPLICAS_DOC	"Number of replicas in the metric topic. It must not be higher than the number of brokers in the destination Kafka cluster."
public static final String	TOPIC_RETENTION_BYTES_CONFIG	"topic.retention.bytes"
public static final String	TOPIC_RETENTION_BYTES_DOC	"Retention bytes for the metrics topic."
public static final String	TOPIC_RETENTION_MS_CONFIG	"topic.retention.ms"
public static final String	TOPIC_RETENTION_MS_DOC	"Retention time for the metrics topic."
public static final String	TOPIC_ROLL_MS_CONFIG	"topic.roll.ms"
public static final String	TOPIC_ROLL_MS_DOC	"Log rolling time for the metrics topic."

io.confluent.telemetry.exporter.kafka.ProducerClientConfig

Modifier and Type	Constant Field	Value
public static final String	BOOTSTRAP_SERVERS_CONFIG	"producer.bootstrap.servers"
public static final String	BOOTSTRAP_SERVERS_DOC	"Bootstrap servers for the Kafka cluster telemetry will be published to. The target cluster may be different from the cluster(s) whose telemetry is being collected. Several production Kafka clusters can publish to a single target Kafka cluster, for example."
public static final String	PREFIX_PRODUCER	"producer."

io.confluent.telemetry.provider.ControlCenterProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.controlcenter"
public static final String	NAMESPACE	"confluent.controlcenter"

io.confluent.telemetry.provider.KafkaClientProvider

Modifier and Type	Constant Field	Value
public static final String	ADMIN_NAMESPACE	"kafka.admin.client"
public static final String	CONSUMER_NAMESPACE	"kafka.consumer"
public static final String	DOMAIN	"io.confluent.kafka.client"
public static final String	LABEL_CLIENT_ID	"client.id"
public static final String	PRODUCER_NAMESPACE	"kafka.producer"

io.confluent.telemetry.provider.KafkaConnectProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.kafka.connect"
public static final String	NAMESPACE	"kafka.connect"

io.confluent.telemetry.provider.KafkaRestProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.kafka.rest"
public static final String	NAMESPACE	"kafka.rest"

io.confluent.telemetry.provider.KafkaServerProvider

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_BROKER_METRICS_INCLUDE_REGEX	"io.confluent.kafka.server/.*(acl_authorizer/zookeeper_disconnects/total/delta|acl_authorizer/zookeeper_expires/total/delta|broker_failure/zookeeper_disconnects/total/delta|broker_failure/zookeeper_expires/total/delta|broker_topic/bytes_in/total/delta|broker_topic/bytes_out/total/delta|broker_topic/failed_produce_requests/total/delta|broker_topic/failed_fetch_requests/total/delta|broker_topic/produce_message_conversions/total/delta|broker_topic/fetch_message_conversions/total/delta|client_broker_topic/client_bytes_in/delta|client_broker_topic/client_bytes_out/delta|client_broker_topic/client_records_in/delta|client_broker_topic/client_records_out/delta|cluster_link/active_link_count|cluster_link/consumer_offset_committed_rate|cluster_link/consumer_offset_committed_total|cluster_link/fetch_throttle_time_avg|cluster_link/fetch_throttle_time_max|cluster_link/link_count|cluster_link/linked_leader_epoch_change_rate|cluster_link/linked_leader_epoch_change_total|cluster_link/linked_topic_partition_addition_rate|cluster_link/linked_topic_partition_addition_total|cluster_link/mirror_partition_count|cluster_link/mirror_topic_byte_total|cluster_link/mirror_topic_count|cluster_link/mirror_topic_lag|cluster_link/topic_config_update_rate|cluster_link/topic_config_update_total|cluster_link_fetcher/connection_count|cluster_link_fetcher/failed_reauthentication_rate|cluster_link_fetcher/failed_reauthentication_total|cluster_link_fetcher/incoming_byte_rate|cluster_link_fetcher/incoming_byte_total|cluster_link_fetcher/outgoing_byte_rate|cluster_link_fetcher/outgoing_byte_total|cluster_link_fetcher/reauthentication_latency_avg|cluster_link_fetcher_manager/max_lag|controller/active_controller_count|controller/leader_election_rate_and_time_ms|controller/offline_partitions_count|controller/partition_availability|controller/preferred_replica_imbalance_count|controller/tenant_partition_availability|controller/global_under_min_isr_partition_count|controller/unclean_leader_elections/total|controller_channel/connection_close_rate|controller_channel/connection_close_total|controller_channel/connection_count|controller_channel/connection_creation_rate|controller_channel/connection_creation_total|controller_channel/request_size_avg|controller_channel/request_size_max|controller_channel_manager/queue_size|controller_channel_manager/total_queue_size|controller_event_manager/event_queue_size|delayed_operation_purgatory/purgatory_size|executor/zookeeper_disconnects/total/delta|executor/zookeeper_expires/total/delta|fetch/queue_size|fetcher/bytes_per_sec|fetcher_lag/consumer_lag|group_coordinator/partition_load_time_max|log/log_end_offset|log/log_start_offset|log/total_size|log_cleaner_manager/achieved_cleaning_ratio/time/delta|log_cleaner_manager/achieved_cleaning_ratio/total/delta|log_cleaner_manager/compacted_partition_bytes|log_cleaner_manager/max_dirty_percent|log_cleaner_manager/time_since_last_run_ms|log_cleaner_manager/uncleanable_bytes|log_cleaner_manager/uncleanable_partitions_count|replica_alter_log_dirs_manager/max_lag|replica_fetcher/request_size_avg|replica_fetcher/request_size_max|replica_fetcher_manager/max_lag|replica_manager/blocked_on_mirror_source_partition_count|replica_manager/isr_shrinks|replica_manager/leader_count|replica_manager/partition_count|replica_manager/under_min_isr_mirror_partition_count|replica_manager/under_min_isr_partition_count|replica_manager/under_replicated_mirror_partitions|replica_manager/under_replicated_partitions|request/errors/total/delta|request/local_time_ms/time/delta|request/local_time_ms/total/delta|request/queue_size|request/remote_time_ms/time/delta|request/remote_time_ms/total/delta|request/request_queue_time_ms/time/delta|request/request_queue_time_ms/total/delta|request/requests|request/response_queue_time_ms/time/delta|request/response_queue_time_ms/total/delta|request/response_send_time_ms/time/delta|request/response_send_time_ms/total/delta|request/total_time_ms/time/delta|request/total_time_ms/total/delta|request_channel/request_queue_size|request_channel/response_queue_size|request_handler_pool/request_handler_avg_idle_percent|session_expire_listener/zookeeper_disconnects/total/delta|session_expire_listener/zookeeper_expires/total/delta|socket_server/connections|socket_server/successful_authentication_total/delta|socket_server/failed_authentication_total/delta|socket_server/network_processor_avg_idle_percent|socket_server/request_size_avg|socket_server/request_size_max|tenant/consumer_lag_offsets)"
public static final String	DEFAULT_CLIENT_TELEMETRY_METRICS_INCLUDE_REGEX	"org\\.apache\\.kafka\\.(producer\\.connection\\.creation\\.rate|producer\\.node\\.request\\.latency\\.avg|producer\\.node\\.request\\.latency\\.max|producer\\.produce\\.throttle\\.time\\.avg|producer\\.produce\\.throttle\\.time\\.max|producer\\.record\\.queue\\.time\\.avg|producer\\.record\\.queue\\.time\\.max|producer\\.connection\\.creation\\.total|consumer\\.connection\\.creation\\.rate|consumer\\.connection\\.creation\\.total|consumer\\.node\\.request\\.latency\\.avg|consumer\\.node\\.request\\.latency\\.max|consumer\\.poll\\.idle\\.ratio\\.avg|consumer\\.coordinator\\.commit\\.latency\\.avg|consumer\\.coordinator\\.commit\\.latency\\.max|consumer\\.coordinator\\.assigned\\.partitions|consumer\\.coordinator\\.rebalance\\.latency\\.avg|consumer\\.coordinator\\.rebalance\\.latency\\.max|consumer\\.coordinator\\.rebalance\\.latency\\.total|consumer\\.fetch\\.manager\\.fetch\\.latency\\.avg|consumer\\.fetch\\.manager\\.fetch\\.latency\\.max)"
public static final String	DEFAULT_SECURITY_METRICS_INCLUDE_REGEX	"io.confluent.kafka.server/.*(confluent_audit/audit_log_fallback_rate_per_minute|confluent_audit/audit_log_rate_per_minute|confluent_authorizer/authorization_request_rate_per_minute|confluent_authorizer/authorization_allowed_rate_per_minute|confluent_authorizer/authorization_denied_rate_per_minute|confluent_auth_store/rbac_role_bindings_count|confluent_auth_store/rbac_access_rules_count|confluent_auth_store/acl_access_rules_count)"
public static final String	LABEL_BROKER_ID	"broker.id"
public static final String	LABEL_BROKER_RACK	"broker.rack"
public static final String	LABEL_CELL_ID	"cell.id"
public static final String	LABEL_CLUSTER_ID	"cluster.id"
public static final String	LABEL_PROCESS_BROKER	"process.roles.broker"
public static final String	LABEL_PROCESS_CONTROLLER	"process.roles.controller"
public static final String	LABEL_PROCESS_ROLES	"process.roles"
public static final String	NAMESPACE	"kafka.server"

io.confluent.telemetry.provider.KafkaStreamsProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.kafka.streams"
public static final String	NAMESPACE	"kafka.streams"
public static final String	STREAMS_APPLICATION_ID	"application.id"

io.confluent.telemetry.provider.KsqlProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.ksql"
public static final String	KSQL_SERVICE_ID	"ksql.service.id"
public static final String	NAMESPACE	"io.confluent.ksql.metrics"

io.confluent.telemetry.provider.SchemaRegistryProvider

Modifier and Type	Constant Field	Value
public static final String	DOMAIN	"io.confluent.schema.registry"
public static final String	NAMESPACE	"kafka.schema.registry"
public static final String	SCHEMAS_TOPIC_CONFIG	"kafkastore.topic"

io.confluent.telemetry.provider.Utils

Modifier and Type	Constant Field	Value
public static final String	CONNECT_GROUP_ID	"connect.group.id"
public static final String	CONNECT_KAFKA_CLUSTER_ID	"connect.kafka.cluster.id"
public static final String	KAFKA_BROKER_ID	"kafka.broker.id"
public static final String	KAFKA_BROKER_ROLE	"broker"
public static final String	KAFKA_CELL_ID	"kafka.cell.id"
public static final String	KAFKA_CLUSTER_ID	"kafka.cluster.id"
public static final String	KAFKA_CONTROLLER_ROLE	"controller"
public static final String	KAFKA_NODE_ID	"kafka.node.id"
public static final String	KAFKA_PROCESS_ROLES	"kafka.process.roles"
public static final String	LABEL_CLUSTER_ID	"cluster.id"
public static final String	RESOURCE_LABEL_CLUSTER_ID	"resource.cluster.id"

io.confluent.telemetry.reporter.TelemetryReporter

Modifier and Type	Constant Field	Value
public static final String	CONFLUENT_METRICS_COMMIT_ID_TAG	"confluent_metrics_commit_id"
public static final String	CONFLUENT_METRICS_VERSION_TAG	"confluent_metrics_version"
public static final String	SELF_METRICS_DOMAIN	"io.confluent.telemetry"
public static final String	SELF_METRICS_NAMESPACE	"confluent.telemetry"
public static final String	TELEMETRY_REPORTER_ID_TAG	"telemetry-reporter-id"