Index

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values

A

AbstractExporter - Class in io.confluent.telemetry.exporter

AbstractExporter(Predicate<Keyed>, String) - Constructor for class io.confluent.telemetry.exporter.AbstractExporter

addClientConfig(String, Map<String, Object>) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

addExporterConfig(String, Map<String, Object>) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

ADMIN_NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider

AggregatingEmitter - Class in io.confluent.telemetry.emitter

Wraps an Emitter with aggregation capability.

AggregatingEmitter(Set<AggregationRule>, Emitter) - Constructor for class io.confluent.telemetry.emitter.AggregatingEmitter

allExporters() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

allExportersWithNames(Set<String>) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

allHttpClients() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

allHttpExporters() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

ALWAYS_FALSE - Static variable in class io.confluent.telemetry.PredicateUtils

ALWAYS_TRUE - Static variable in class io.confluent.telemetry.PredicateUtils

API_KEY - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

API_KEY - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

API_KEY_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

API_KEY_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

API_SECRET - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

API_SECRET - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

API_SECRET_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

API_SECRET_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

asAttributes(Map<String, String>) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

attributesMap(Resource) - Static method in class io.confluent.telemetry.MetricsUtils

Convert resource attributes to a map of strings, ignoring non-string attributes

attributesMap(List<KeyValue>) - Static method in class io.confluent.telemetry.MetricsUtils

B

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

BOOTSTRAP_SERVERS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

BOOTSTRAP_SERVERS_DEFAULT - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

BOOTSTRAP_SERVERS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

BrokerConfigUtils - Class in io.confluent.telemetry

This class was created to extract the interbroker client configs from the broker at runtime.

BrokerConfigUtils() - Constructor for class io.confluent.telemetry.BrokerConfigUtils

BUFFER_MAX_BATCH_DURATION_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_BATCH_DURATION_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_DURATION_MS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_BATCH_DURATION_MS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_SIZE - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_BATCH_SIZE - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_BATCH_SIZE_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_BATCH_SIZE_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_INFLIGHT_SUBMISSIONS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_PENDING_BATCHES - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_PENDING_BATCHES - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

BUFFER_MAX_PENDING_BATCHES_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

BUFFER_MAX_PENDING_BATCHES_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

build() - Method in class io.confluent.telemetry.collector.JvmMetricsCollector.Builder

build() - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder

build() - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

build() - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder

build() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

build() - Method in class io.confluent.telemetry.MetricKey.Builder

build() - Method in class io.confluent.telemetry.ResourceBuilderFacade

buildCachingMetricsPredicate(String) - Static method in class io.confluent.telemetry.PredicateUtils

Builder() - Constructor for class io.confluent.telemetry.ConfigPropertyTranslater.Builder

buildMetricsData(ExportableMetric) - Static method in interface io.confluent.telemetry.exporter.ExportableMetric

Construct a MetricsData by binding the underlying Metric to the Resource and InstrumentationScope in this ExportableMetric.

buildMetricsPredicate() - Method in class io.confluent.telemetry.exporter.ExporterConfig

Gets the exporter specific predicated if the `metrics.include` is set.

buildRequest(Collection<ExportableMetric>) - Static method in interface io.confluent.telemetry.exporter.ExportableMetric

Construct a ExportMetricsServiceRequest by binding the underlying Metric to the Resource and InstrumentationScope in this ExportableMetric.

buildResourceFromAllLabelsWithId(MetricsContext, String) - Static method in class io.confluent.telemetry.provider.Utils

buildResourceFromLabels(MetricsContext) - Static method in class io.confluent.telemetry.provider.Utils

Build a Resource from tags in the MetricsContext metadata.

buildResourceFromLabelsWithId(MetricsContext, String) - Static method in class io.confluent.telemetry.provider.Utils

C

calculateDelay(int) - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

Calculates the delay for a specific retry attempt using exponential backoff.

cleanLabelNames(Map<String, String>) - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

Converts the label keys to snake_case.

CLIENT_BASE_URL - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_BASE_URL - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_BASE_URL_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_BASE_URL_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_COMPRESSION - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_COMPRESSION - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_COMPRESSION_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_COMPRESSION_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_CONFLUENT_DEFAULTS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CLIENT_CONFLUENT_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CLIENT_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_CONNECT_TIMEOUT_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_DEFAULT_CONFIGS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CLIENT_MAX_ATTEMPTS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_MAX_ATTEMPTS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_MAX_ATTEMPTS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_MAX_ATTEMPTS_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_METRICS_PATH - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_METRICS_PATH - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_METRICS_PATH_DEFAULT - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_METRICS_PATH_DEFAULT - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_METRICS_PATH_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_METRICS_PATH_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_NAME_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

CLIENT_NAME_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

CLIENT_NAME_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

CLIENT_PORT - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_PORT - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_PORT_DEFAULT - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_PORT_DEFAULT - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_PORT_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_PORT_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_REQUEST_TIMEOUT_MS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_REQUEST_TIMEOUT_MS_DOCS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_REQUEST_TIMEOUT_MS_DOCS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_RETRY_DELAY_SEC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_RETRY_DELAY_SEC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CLIENT_RETRY_DELAY_SEC_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

CLIENT_RETRY_DELAY_SEC_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

ClientConfig - Class in io.confluent.telemetry.exporter

ClientConfig(String, ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.ClientConfig

ClientConfig.ClientConfigType - Enum Class in io.confluent.telemetry.exporter

ClientExportableMetric - Class in io.confluent.telemetry.emitter

The ClientExportableMetric class extends ContextExportableMetric to process client metrics telemetry data.

ClientExportableMetric(Metric, MetricKey, Context, Resource, Map<String, String>, Map<String, String>, Set<String>) - Constructor for class io.confluent.telemetry.emitter.ClientExportableMetric

ClientLabels - Class in io.confluent.telemetry.emitter

The ClientLabels class provides functionality to extract and clean up metric labels.

ClientLabels() - Constructor for class io.confluent.telemetry.emitter.ClientLabels

ClientMetricsTelemetryReceiver - Class in io.confluent.telemetry.emitter

ClientMetricsTelemetryReceiver implements the ClientTelemetryReceiver interface to receive client telemetry metrics, augment them with additional labels, and emit them using a provided telemetry emitter.

ClientMetricsTelemetryReceiver(TelemetryEmitter, Context, Map<String, String>, Set<String>) - Constructor for class io.confluent.telemetry.emitter.ClientMetricsTelemetryReceiver

clientPrefixForName(String) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig

clientReceiver() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

close() - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter

close() - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

Called when the metrics repository is closed.

close() - Method in class io.confluent.telemetry.exporter.http.HttpExporter

close() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

close() - Method in class io.confluent.telemetry.MetricsCollectorTask

close() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

Called when the metrics repository is closed.

close() - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

close() - Method in class io.confluent.telemetry.serde.ProtoToJson

CloseableReferenceTracker<R,T> - Class in io.confluent.telemetry.exporter

CloseableReferenceTracker(String, CloseableReferenceTracker.CloseableFactory<R, T>) - Constructor for class io.confluent.telemetry.exporter.CloseableReferenceTracker

CloseableReferenceTracker.CloseableFactory<R,T> - Interface in io.confluent.telemetry.exporter

CLUSTER_ID_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CLUSTER_ID_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

collect(Emitter) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector

collect(Emitter) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector

collect(Emitter) - Method in interface io.confluent.telemetry.collector.MetricsCollector

collect(Emitter) - Method in class io.confluent.telemetry.collector.SharedJvmMetricsCollector

Collect JVM metrics if this is the active instance.

collect(Emitter) - Method in class io.confluent.telemetry.collector.SLOMetricsCollector

collect(Emitter) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector

collect(Emitter) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector

COLLECT_INTERVAL_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

COLLECT_INTERVAL_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

collectKafkaMetrics(Map<MetricName, KafkaMetric>, Pattern) - Static method in class io.confluent.metrics.reporter.KafkaMetricsHelper

collectYammerMetrics(MetricsRegistry, Pattern) - Method in class io.confluent.metrics.reporter.YammerMetricsHelper

CONFIG_EVENTS_ENABLE_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_ENABLE_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_ENABLE_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_INCLUDE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_INCLUDE_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_INCLUDE_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_EVENTS_INCLUDE_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

CONFIG_MAP_NAME_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

CONFIG_MAP_NAME_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

configEvent(Map<String, ?>, Predicate<String>, Resource, Provider, String) - Static method in class io.confluent.telemetry.provider.Utils

configInclude() - Method in class io.confluent.telemetry.provider.KafkaServerProvider

configInclude() - Method in interface io.confluent.telemetry.provider.Provider

Include list for config

configPredicate(String) - Static method in class io.confluent.telemetry.provider.Utils

ConfigPropertyTranslater - Class in io.confluent.telemetry

Translates map keys according to configured rules.

ConfigPropertyTranslater.Builder - Class in io.confluent.telemetry

configure(Map<String, ?>) - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter

configure(Map<String, ?>) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

Configure this class with the given key-value pairs

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.ControlCenterProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaClientProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaRestProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaServerProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KsqlProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

configure(Map<String, ?>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

Note: we are assuming that these methods are invoked in the following order: 1.

configure(Map<String, ?>, boolean) - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

configure(Map, boolean) - Method in class io.confluent.telemetry.serde.ProtoToJson

configureClientDefaults(TelemetryHttpClient.Builder<T, S>) - Method in class io.confluent.telemetry.exporter.http.HttpClientConfig

configureClientDefaults(TelemetryHttpClient.Builder<T, S>) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

configureMapper(ObjectMapper) - Static method in interface io.confluent.telemetry.config.remote.RemoteConfigurationSource

ConfigUtils - Class in io.confluent.telemetry.common.config

ConfigUtils() - Constructor for class io.confluent.telemetry.common.config.ConfigUtils

CONFLUENT_METRICS_COMMIT_ID_TAG - Static variable in class io.confluent.telemetry.reporter.TelemetryReporter

CONFLUENT_METRICS_VERSION_TAG - Static variable in class io.confluent.telemetry.reporter.TelemetryReporter

ConfluentMetricNamingConvention - Class in io.confluent.telemetry.collector

This class encapsulates Confluent naming and mapping conventions defined as part of https://confluentinc.atlassian.net/wiki/spaces/OBSERVE/pages/890537142/Metrics+Conventions

ConfluentMetricNamingConvention() - Constructor for class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

ConfluentMetricsFormatter - Class in io.confluent.metrics.reporter

ConfluentMetricsFormatter() - Constructor for class io.confluent.metrics.reporter.ConfluentMetricsFormatter

ConfluentMetricsReporter - Class in io.confluent.metrics.reporter

ConfluentMetricsReporter() - Constructor for class io.confluent.metrics.reporter.ConfluentMetricsReporter

ConfluentMetricsReporterConfig - Class in io.confluent.metrics.reporter

ConfluentMetricsReporterConfig(Map<String, ?>) - Constructor for class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

ConfluentMetricsVersion - Class in io.confluent.telemetry.reporter

Provides the build-time version and commit ID of the confluent-metrics library.

ConfluentTelemetryConfig - Class in io.confluent.telemetry

ConfluentTelemetryConfig(Map<String, ?>) - Constructor for class io.confluent.telemetry.ConfluentTelemetryConfig

ConfluentTelemetryConfig(Map<String, ?>, boolean) - Constructor for class io.confluent.telemetry.ConfluentTelemetryConfig

CONNECT_GROUP_ID - Static variable in class io.confluent.telemetry.provider.Utils

CONNECT_KAFKA_CLUSTER_ID - Static variable in class io.confluent.telemetry.provider.Utils

CONNECT_TIMEOUT_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

CONNECT_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

CONNECTION_SSL_CONFIG_PREFIX - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

CONSUMER_NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider

contains(MetricKey) - Method in class io.confluent.telemetry.collector.LastValueTracker

Context - Class in io.confluent.telemetry

Context for metrics collectors.

Context(Resource, String) - Constructor for class io.confluent.telemetry.Context

Context(Resource, String, boolean) - Constructor for class io.confluent.telemetry.Context

Context(String) - Constructor for class io.confluent.telemetry.Context

contextChange(MetricsContext) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.ControlCenterProvider

A callback method that a user can implement to get updates for MetricsContext.

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KafkaClientProvider

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KafkaRestProvider

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KafkaServerProvider

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.KsqlProvider

contextChange(MetricsContext) - Method in interface io.confluent.telemetry.provider.Provider

Sets the metrics labels for the service or library exposing metrics.

contextChange(MetricsContext) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

A callback method that a user can implement to get updates for MetricsContext.

contextChange(MetricsContext) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

ContextExportableMetric - Class in io.confluent.telemetry.emitter

ContextExportableMetric(Metric, MetricKey, Context) - Constructor for class io.confluent.telemetry.emitter.ContextExportableMetric

ControlCenterProvider - Class in io.confluent.telemetry.provider

ControlCenterProvider() - Constructor for class io.confluent.telemetry.provider.ControlCenterProvider

convertCase(String) - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

Converts a tag/name to match the telemetry naming conventions by converting snake_case.

count(String, Map<String, String>) - Method in class io.confluent.logredactor.KafkaSensorLogRedactorMetrics

CPU_METRIC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

create(MetricKey, Metric.Builder) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

create(R) - Method in interface io.confluent.telemetry.exporter.CloseableReferenceTracker.CloseableFactory

createCounterSensor(String, String, String, Map<String, String>) - Method in class io.confluent.telemetry.metrics.otel.OpenTelemetryReporterSelfMetrics

createCounterSensor(String, String, String, Map<String, String>) - Method in interface io.confluent.telemetry.metrics.TelemetryReporterSelfMetrics

createGaugeSensor(String, String, String, Map<String, String>) - Method in class io.confluent.telemetry.metrics.otel.OpenTelemetryReporterSelfMetrics

createGaugeSensor(String, String, String, Map<String, String>) - Method in interface io.confluent.telemetry.metrics.TelemetryReporterSelfMetrics

createProxy(CloseableReferenceTracker<R, T>) - Static method in class io.confluent.telemetry.exporter.ReferenceTrackingProxy

cumulativeSum(MetricKey, double, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

cumulativeSum(MetricKey, double, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

cumulativeSum(MetricKey, long, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

cumulativeSum(MetricKey, long, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

D

DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEBUG_ENABLED_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_ACTIVE_FILTER_SET - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_BROKER_KAFKA_METRICS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_BROKER_METRICS_INCLUDE_REGEX - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

DEFAULT_BROKER_YAMMER_METRICS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_CLIENT_TELEMETRY_METRICS_INCLUDE_REGEX - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

DEFAULT_COLLECT_INTERVAL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_CONNECT_TIMEOUT - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

DEFAULT_DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_ENABLED - Static variable in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration

DEFAULT_MAX_RETRY_ATTEMPTS - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

DEFAULT_METRICS_INCLUDE - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_METRICS_INCLUDE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_MIN_ISR - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_MIN_ISR - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_NAMED_FILTER_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_NAMESPACE - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

DEFAULT_PUBLISH_PERIOD - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_READ_TIMEOUT - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

DEFAULT_REFRESH_INTERVAL - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

DEFAULT_RETRY_BACKOFF_MULTIPLIER - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

DEFAULT_RETRY_INITIAL_DELAY_MS - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

DEFAULT_RETRY_MAX_DELAY_MS - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

DEFAULT_SECURITY_METRICS_INCLUDE_REGEX - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

DEFAULT_SLO_COLLECTOR_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_SYSTEM_METRICS_INCLUDE_REGEX - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

DEFAULT_TOPIC_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_CREATE - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_CREATE_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_MAX_MESSAGE_BYTES - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_MAX_MESSAGE_BYTES_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_NAME - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_PARTITIONS - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_REPLICAS - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_RETENTION_BYTES - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_RETENTION_MS - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_TOPIC_ROLL_MS - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

DEFAULT_TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_VOLUME_METRICS_REFRESH_PERIOD - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

DEFAULT_VOLUME_METRICS_UPDATE_PERIOD - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

defineConfigs(ConfigDef) - Static method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

deltaSum(MetricKey, double, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

deltaSum(MetricKey, long, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

derivedMetricKey(MetricKey, String) - Method in interface io.confluent.telemetry.collector.MetricNamingStrategy

Creates a derived metric key from an existing metric key.

deriveLocalProducerConfigs(Map<String, Object>) - Static method in class io.confluent.telemetry.BrokerConfigUtils

deserialize(String, byte[]) - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

deserialize(String, byte[]) - Method in class io.confluent.telemetry.serde.ProtoToJson

deserialize(String, Headers, byte[]) - Method in class io.confluent.telemetry.serde.ProtoToJson

deserializer() - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

doEmit(ContextExportableMetric) - Method in class io.confluent.telemetry.exporter.AbstractExporter

doEmit(ContextExportableMetric) - Method in class io.confluent.telemetry.exporter.http.HttpExporter

doEmit(ContextExportableMetric) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

domain() - Method in class io.confluent.telemetry.provider.ControlCenterProvider

domain() - Method in class io.confluent.telemetry.provider.KafkaClientProvider

domain() - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

domain() - Method in class io.confluent.telemetry.provider.KafkaRestProvider

domain() - Method in class io.confluent.telemetry.provider.KafkaServerProvider

domain() - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

domain() - Method in class io.confluent.telemetry.provider.KsqlProvider

domain() - Method in interface io.confluent.telemetry.provider.Provider

Domain of the active provider.

domain() - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.ControlCenterProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.KafkaConnectProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.KafkaRestProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.KafkaStreamsProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.KsqlProvider

DOMAIN - Static variable in class io.confluent.telemetry.provider.SchemaRegistryProvider

E

emit(ContextExportableMetric) - Method in class io.confluent.telemetry.exporter.AbstractExporter

emit(ContextExportableMetric) - Method in interface io.confluent.telemetry.exporter.Exporter

emitMetric(ContextExportableMetric) - Method in class io.confluent.telemetry.emitter.TelemetryEmitter

emitMetric(SinglePointMetric) - Method in class io.confluent.telemetry.emitter.AggregatingEmitter

emitMetric(SinglePointMetric) - Method in interface io.confluent.telemetry.emitter.Emitter

Emits a metric to all configured Exporter objects.

emitMetric(SinglePointMetric) - Method in class io.confluent.telemetry.emitter.TelemetryEmitter

emitter() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

Emitter - Interface in io.confluent.telemetry.emitter

EMPTY_STRING - Static variable in class io.confluent.metrics.reporter.Utils

ENABLED_CONFIG - Static variable in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration

ENABLED_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration

ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

enabledExporters() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

ensureValid(String, Object) - Method in class io.confluent.telemetry.exporter.http.HttpConfigUtils.URIValidator

ensureValid(String, Object) - Method in class io.confluent.telemetry.RegexConfigDefValidator

equals(Object) - Method in class io.confluent.telemetry.config.FilterSetPredicate

equals(Object) - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

equals(Object) - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

equals(Object) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

equals(Object) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfigWrapper

equals(Object) - Method in class io.confluent.telemetry.MetricKey

eventEmitter() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

EVENTS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

EVENTS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

EVENTS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

EXCLUDE_ALL - Static variable in interface io.confluent.telemetry.provider.Provider

executeWithRetry(Supplier<RequestConfigResult>, RetryConfig) - Method in class io.confluent.telemetry.config.remote.polling.RetryHandler

Executes the given supplier with retry logic and exponential backoff.

ExportableMetric - Interface in io.confluent.telemetry.exporter

The ExportableMetric interface represents a metric that can be exported.

Exporter - Interface in io.confluent.telemetry.exporter

EXPORTER_C3PLUSPLUS_DEFAULTS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_C3PLUSPLUS_METRICS_INCLUDE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_C3PLUSPLUS_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_CONFLUENT_DEFAULTS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_CONFLUENT_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_DEFAULT_CONFIGS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_LOCAL_DEFAULTS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_LOCAL_METRICS_INCLUDE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

EXPORTER_LOCAL_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

ExporterConfig - Class in io.confluent.telemetry.exporter

ExporterConfig(String, ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.ExporterConfig

ExporterConfig.ExporterType - Enum Class in io.confluent.telemetry.exporter

exporterPrefixForName(String) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig

exportMetrics(AuthorizableRequestContext, ClientTelemetryPayload) - Method in class io.confluent.telemetry.emitter.ClientMetricsTelemetryReceiver

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.ControlCenterProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KafkaClientProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KafkaRestProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KafkaServerProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.KsqlProvider

extraCollectors(Context) - Method in interface io.confluent.telemetry.provider.Provider

The collector for Kafka Metrics library is enabled by default.

extraCollectors(Context) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

extractDataPoints(Metric) - Static method in class io.confluent.telemetry.MetricsUtils

Extracts the list of data points from the given metric based on its type.

F

FileRemoteConfigConfiguration - Class in io.confluent.telemetry.config.remote.file

FileRemoteConfigConfiguration(Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.file.FileRemoteConfigConfiguration

FileRemoteConfigSource - Class in io.confluent.telemetry.config.remote.file

A RemoteConfigurationSource that supports reading from a local file.

FileRemoteConfigSource(FileRemoteConfigConfiguration, Consumer<RemoteConfiguration>) - Constructor for class io.confluent.telemetry.config.remote.file.FileRemoteConfigSource

FilterSetPredicate - Class in io.confluent.telemetry.config

A grouping of unique NamedPredicates to be applied to an Exporter.

flushAggregates() - Method in class io.confluent.telemetry.emitter.AggregatingEmitter

forAggregatedMetrics() - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

forKafkaMetrics(String, boolean, boolean) - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

forYammerMetrics(String, boolean, boolean) - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

from(PollingRemoteConfigurationConfig) - Static method in class io.confluent.telemetry.config.remote.polling.RetryConfig

Creates a RetryConfig from PollingRemoteConfigurationConfig.

fromNamedFilter(NamedFilter) - Static method in class io.confluent.telemetry.config.FilterSetPredicate

fromNamedFilter(Set<NamedFilter>) - Static method in class io.confluent.telemetry.config.FilterSetPredicate

fromTimeUnixNanos(long) - Static method in class io.confluent.telemetry.MetricsUtils

fullMetricName(String, String, String) - Static method in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

Creates a metric name given the domain, group, and name.

G

gauge(double, String, Map<String, String>) - Method in class io.confluent.logredactor.KafkaSensorLogRedactorMetrics

gauge(MetricKey, double, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

gauge(MetricKey, long, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

gauge(MetricKey, Number, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

creates a metric data point for arbitrary Number values.

gauges - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult

get(HttpExporterConfigWrapper) - Method in class io.confluent.telemetry.exporter.http.HttpClientFactory

Retrieves or creates a BufferingAsyncClient instance based on the provided configuration wrapper.

get(ProducerClientConfig, Properties) - Method in class io.confluent.telemetry.exporter.kafka.KafkaClientFactory

Retrieves or creates a KafkaProducer instance based on the provided configuration.

getAndSet(MetricKey, Instant, T) - Method in class io.confluent.telemetry.collector.LastValueTracker

Return the last instant/value for the given MetricKey, or Optional.empty if there isn't one.

getBalanceReplicationFactor(Map<String, Object>) - Static method in class io.confluent.telemetry.BrokerConfigUtils

return the config value for ConfluentConfigs.BALANCER_TOPICS_REPLICATION_FACTOR_CONFIG

getBrokerRack(Map<String, Object>) - Static method in class io.confluent.telemetry.BrokerConfigUtils

getClientConfig() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

getClientConfig() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

getClientMetricsExcludeLabels() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

getClientMetricsPath() - Method in class io.confluent.telemetry.exporter.http.HttpClientConfig

getClientMetricsPath() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

getClientName() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

getClientName() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

getCollectors() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

getCommitId() - Static method in class io.confluent.telemetry.reporter.ConfluentMetricsVersion

getConfig() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

getConfig() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

getConfig() - Method in interface io.confluent.telemetry.config.remote.RemoteConfigurationSource

Returns the latest received configuration from this source.

getCredentials() - Method in class io.confluent.telemetry.exporter.http.HttpClientConfig

getCredentials() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

getData() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1Object

getDefaultFilterSet() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

getDomain() - Method in class io.confluent.telemetry.Context

getError() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

getErrorMessage() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

getInstance() - Static method in class io.confluent.telemetry.exporter.http.HttpClientFactory

getInstance() - Static method in class io.confluent.telemetry.exporter.kafka.KafkaClientFactory

getInstrumentationScope() - Method in class io.confluent.telemetry.Context

Get the InstrumentationScope in this Context.

getInterBrokerEndpoint(Map<String, Object>) - Static method in class io.confluent.telemetry.BrokerConfigUtils

getIntervalStart() - Method in class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue

getKind() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1Object

getLabels() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

getLabels() - Method in class io.confluent.telemetry.HostResourceLabelProvider

getLabels() - Method in class io.confluent.telemetry.JavaRuntimeResourceLabelProvider

getLabels() - Method in class io.confluent.telemetry.MetricKey

getLabels() - Method in interface io.confluent.telemetry.ResourceLabelProvider

Get labels to be set on the Resource.

getMaxAttempts() - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

getMaxRetryAttempts() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

getMetadata() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1Object

getMetrics() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider

getMetrics() - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector

getName() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1ObjectMeta

getName() - Method in class io.confluent.telemetry.exporter.AbstractExporter

getName() - Method in class io.confluent.telemetry.exporter.ClientConfig

getName() - Method in interface io.confluent.telemetry.exporter.Exporter

getName() - Method in class io.confluent.telemetry.exporter.ExporterConfig

getName() - Method in class io.confluent.telemetry.MetricKey

getNamespace() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1ObjectMeta

getNonResourceLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils

getPredicate() - Method in class io.confluent.telemetry.exporter.AbstractExporter

getPredicate() - Method in interface io.confluent.telemetry.exporter.Exporter

getProducer() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

getProducerProperties() - Method in class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

getProducerProperties(Map<String, Object>) - Static method in class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

getProvider(String) - Static method in class io.confluent.telemetry.provider.ProviderRegistry

getProxyConfig() - Method in class io.confluent.telemetry.exporter.http.HttpClientConfig

getProxyConfig() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

getRefreshInterval() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

getRemoteConfigConfiguration() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

getResource() - Method in class io.confluent.telemetry.Context

Get the Resource in this Context.

getResourceLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils

Extract the resource labels from the metrics context metadata and remove metrics context prefix.

getResourceVersion() - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.V1ObjectMeta

getRetryBackoffMultiplier() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

getRetryInitialDelayMs() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

getRetryMaxDelayMs() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

getSelfMetrics() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

getSslContext() - Method in class io.confluent.telemetry.exporter.http.SslFactory

getType() - Method in class io.confluent.telemetry.exporter.ClientConfig

getType() - Method in class io.confluent.telemetry.exporter.ExporterConfig

getValue() - Method in class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue

getVersion() - Static method in class io.confluent.telemetry.reporter.ConfluentMetricsVersion

getVolumeMetricsCollectorConfig() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

H

hasClientWithName(String) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

hasExporterWithName(String) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

hashCode() - Method in class io.confluent.telemetry.config.FilterSetPredicate

hashCode() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

hashCode() - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

hashCode() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

hashCode() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfigWrapper

hashCode() - Method in class io.confluent.telemetry.MetricKey

hasNamedClient() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

hasNativeClientConfigs() - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

histograms - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult

HostResourceLabelProvider - Class in io.confluent.telemetry

Provides labels for host information.

HostResourceLabelProvider() - Constructor for class io.confluent.telemetry.HostResourceLabelProvider

http - Enum constant in enum class io.confluent.telemetry.exporter.ExporterConfig.ExporterType

HttpClientConfig - Class in io.confluent.telemetry.exporter.http

HttpClientConfig(String, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.http.HttpClientConfig

HttpClientFactory - Class in io.confluent.telemetry.exporter.http

HttpClientFactory() - Constructor for class io.confluent.telemetry.exporter.http.HttpClientFactory

HttpConfigUtils - Class in io.confluent.telemetry.exporter.http

HttpConfigUtils.URIValidator - Class in io.confluent.telemetry.exporter.http

HttpExporter - Class in io.confluent.telemetry.exporter.http

HttpExporter(Predicate<Keyed>, String, HttpExporterConfig) - Constructor for class io.confluent.telemetry.exporter.http.HttpExporter

HttpExporterConfig - Class in io.confluent.telemetry.exporter.http

Configuration for the HttpExporter.

HttpExporterConfig(String, Map<String, ?>) - Constructor for class io.confluent.telemetry.exporter.http.HttpExporterConfig

HttpExporterConfig(String, Map<String, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.http.HttpExporterConfig

HttpExporterConfig(String, Map<String, ?>, HttpClientConfig, boolean) - Constructor for class io.confluent.telemetry.exporter.http.HttpExporterConfig

HttpExporterConfigWrapper - Class in io.confluent.telemetry.exporter.http

HttpRemoteConfigurationSource - Class in io.confluent.telemetry.config.remote.polling

HttpRemoteConfigurationSource(TelemetryHttpClient.Builder<RemoteConfigurationRequest, RemoteConfigurationResponse>, long, Consumer<RemoteConfiguration>, Resource) - Constructor for class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

httpTelemetryClient - Enum constant in enum class io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

I

init(List<KafkaMetric>) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

This is called when the reporter is first registered to initially register all existing metrics

init(List<KafkaMetric>) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector

init(List<KafkaMetric>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

InstantAndValue(Instant, T) - Constructor for class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue

instrumentationScope() - Method in class io.confluent.telemetry.emitter.ContextExportableMetric

instrumentationScope() - Method in interface io.confluent.telemetry.exporter.ExportableMetric

invoke(Object, Method, Object[]) - Method in class io.confluent.telemetry.exporter.ReferenceTrackingProxy

io.confluent.logredactor - package io.confluent.logredactor

io.confluent.metrics.reporter - package io.confluent.metrics.reporter

io.confluent.telemetry - package io.confluent.telemetry

io.confluent.telemetry.collector - package io.confluent.telemetry.collector

io.confluent.telemetry.common.config - package io.confluent.telemetry.common.config

io.confluent.telemetry.config - package io.confluent.telemetry.config

io.confluent.telemetry.config.remote - package io.confluent.telemetry.config.remote

io.confluent.telemetry.config.remote.file - package io.confluent.telemetry.config.remote.file

io.confluent.telemetry.config.remote.polling - package io.confluent.telemetry.config.remote.polling

io.confluent.telemetry.config.remote.polling.kubernetes - package io.confluent.telemetry.config.remote.polling.kubernetes

io.confluent.telemetry.emitter - package io.confluent.telemetry.emitter

io.confluent.telemetry.exporter - package io.confluent.telemetry.exporter

io.confluent.telemetry.exporter.http - package io.confluent.telemetry.exporter.http

io.confluent.telemetry.exporter.kafka - package io.confluent.telemetry.exporter.kafka

io.confluent.telemetry.metrics - package io.confluent.telemetry.metrics

io.confluent.telemetry.metrics.otel - package io.confluent.telemetry.metrics.otel

io.confluent.telemetry.provider - package io.confluent.telemetry.provider

io.confluent.telemetry.reporter - package io.confluent.telemetry.reporter

io.confluent.telemetry.serde - package io.confluent.telemetry.serde

isDebugEnabled() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

isDebugEnabled() - Method in class io.confluent.telemetry.Context

isEnabled() - Method in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration

isEnabled() - Method in class io.confluent.telemetry.exporter.ExporterConfig

isError() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

isMetricsEnabled() - Method in class io.confluent.telemetry.exporter.ExporterConfig

isNonRetryableError() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

isNotFound() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

isNoUpdate() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

isRemoteConfigurable() - Method in class io.confluent.telemetry.exporter.ExporterConfig

isRetryableError() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

isRetryEnabled() - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

isSuccess() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

J

JavaRuntimeResourceLabelProvider - Class in io.confluent.telemetry

Provides labels for Java runtime environment information.

JavaRuntimeResourceLabelProvider() - Constructor for class io.confluent.telemetry.JavaRuntimeResourceLabelProvider

joinIncludeRegexList(List<String>) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig

JvmMetricsCollector - Class in io.confluent.telemetry.collector

JvmMetricsCollector.Builder - Class in io.confluent.telemetry.collector

K

kafka - Enum constant in enum class io.confluent.telemetry.exporter.ExporterConfig.ExporterType

KAFKA_BROKER_ID - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_BROKER_ROLE - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_CELL_ID - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_CLUSTER_ID - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_CONTROLLER_ROLE - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_METRICS_LIB - Static variable in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

KAFKA_NODE_ID - Static variable in class io.confluent.telemetry.provider.Utils

KAFKA_PROCESS_ROLES - Static variable in class io.confluent.telemetry.provider.Utils

KafkaClientFactory - Class in io.confluent.telemetry.exporter.kafka

KafkaClientFactory() - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaClientFactory

KafkaClientProvider - Class in io.confluent.telemetry.provider

KafkaClientProvider() - Constructor for class io.confluent.telemetry.provider.KafkaClientProvider

KafkaConnectProvider - Class in io.confluent.telemetry.provider

KafkaConnectProvider() - Constructor for class io.confluent.telemetry.provider.KafkaConnectProvider

KafkaExporter - Class in io.confluent.telemetry.exporter.kafka

KafkaExporter(KafkaExporter.Builder) - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaExporter

KafkaExporter.Builder - Class in io.confluent.telemetry.exporter.kafka

KafkaExporterConfig - Class in io.confluent.telemetry.exporter.kafka

KafkaExporterConfig(String, Map<String, ?>) - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

KafkaExporterConfig(String, Map<String, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

KafkaExporterConfig(String, Map<String, ?>, ProducerClientConfig, boolean) - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

KafkaMetricsCollector - Class in io.confluent.telemetry.collector

KafkaMetricsCollector(MetricNamingStrategy<MetricName>) - Constructor for class io.confluent.telemetry.collector.KafkaMetricsCollector

KafkaMetricsHelper - Class in io.confluent.metrics.reporter

kafkaProducer - Enum constant in enum class io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

KafkaRestProvider - Class in io.confluent.telemetry.provider

KafkaRestProvider() - Constructor for class io.confluent.telemetry.provider.KafkaRestProvider

KafkaSensorLogRedactorMetrics - Class in io.confluent.logredactor

KafkaSensorLogRedactorMetrics() - Constructor for class io.confluent.logredactor.KafkaSensorLogRedactorMetrics

KafkaServerMetricsReporter - Class in io.confluent.telemetry.reporter

Deprecated.

KafkaServerMetricsReporter() - Constructor for class io.confluent.telemetry.reporter.KafkaServerMetricsReporter

Deprecated.

KafkaServerProvider - Class in io.confluent.telemetry.provider

KafkaServerProvider() - Constructor for class io.confluent.telemetry.provider.KafkaServerProvider

KafkaStreamsProvider - Class in io.confluent.telemetry.provider

KafkaStreamsProvider() - Constructor for class io.confluent.telemetry.provider.KafkaStreamsProvider

key() - Method in class io.confluent.telemetry.emitter.ContextExportableMetric

key() - Method in class io.confluent.telemetry.MetricKey

This is a bit weird but prevents from always having to wrap this object if we're already interacting with a MetricKey directly.

key() - Method in interface io.confluent.telemetry.metrics.Keyed

key() - Method in class io.confluent.telemetry.metrics.SinglePointMetric

KEY_HOSTNAME - Static variable in class io.confluent.telemetry.HostResourceLabelProvider

KEY_VERSION - Static variable in class io.confluent.telemetry.JavaRuntimeResourceLabelProvider

Keyed - Interface in io.confluent.telemetry.metrics

An object that supplies a MetricKey that we can use to uniquely identify a metric.

KSQL_SERVICE_ID - Static variable in class io.confluent.telemetry.provider.KsqlProvider

KsqlProvider - Class in io.confluent.telemetry.provider

KsqlProvider() - Constructor for class io.confluent.telemetry.provider.KsqlProvider

KubernetesRemoteConfigurationConfig - Class in io.confluent.telemetry.config.remote.polling.kubernetes

KubernetesRemoteConfigurationConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

KubernetesRemoteConfigurationSource - Class in io.confluent.telemetry.config.remote.polling.kubernetes

This RemoteConfigurationSource will continuously poll the Kubernetes API for ConfigMap and Secret containing the RemoteConfiguration objects.

KubernetesRemoteConfigurationSource(KubernetesRemoteConfigurationConfig, Optional<String>, Consumer<RemoteConfiguration>, TelemetryReporterSelfMetrics) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationSource

L

LABEL_BROKER_ID - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_BROKER_RACK - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_CELL_ID - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_CLIENT_ID - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider

LABEL_CLUSTER_ID - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_CLUSTER_ID - Static variable in class io.confluent.telemetry.provider.Utils

LABEL_LIBRARY - Static variable in interface io.confluent.telemetry.collector.MetricsCollector

Label for the metric instrumentation library

LABEL_ORIGINAL - Static variable in interface io.confluent.telemetry.collector.MetricsCollector

Label for the original (untranslated) metric name

LABEL_PROCESS_BROKER - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_PROCESS_CONTROLLER - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LABEL_PROCESS_ROLES - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

LastValueTracker<T> - Class in io.confluent.telemetry.collector

A LastValueTracker uses a ConcurrentMap to maintain historic values for a given key, and return a previous value and an Instant for that value.

LastValueTracker() - Constructor for class io.confluent.telemetry.collector.LastValueTracker

LastValueTracker.InstantAndValue<T> - Class in io.confluent.telemetry.collector

LIBRARY_NONE - Static variable in interface io.confluent.telemetry.collector.MetricsCollector

"none" value for MetricsCollector.LABEL_LIBRARY

log - Static variable in class io.confluent.telemetry.emitter.TelemetryEmitter

logDirs() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo

M

main(String[]) - Static method in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

main(String[]) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig

main(String[]) - Static method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

main(String[]) - Static method in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

MATCHER_CACHE_MAX_SIZE - Static variable in class io.confluent.telemetry.PredicateUtils

Maximum size of the pattern matcher cache.

MAX_RETRY_ATTEMPTS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

MAX_RETRY_ATTEMPTS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

maybeEmitMetric(SinglePointMetric) - Method in interface io.confluent.telemetry.emitter.Emitter

Emits a metric if Emitter.shouldEmitMetric(Keyed) returns true.

meters - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult

metric() - Method in class io.confluent.telemetry.emitter.ClientExportableMetric

Returns the metric with resource attributes, brokerLabels and requestLabels added to the metric data point.

metric() - Method in class io.confluent.telemetry.emitter.ContextExportableMetric

metric() - Method in interface io.confluent.telemetry.exporter.ExportableMetric

metric() - Method in class io.confluent.telemetry.metrics.SinglePointMetric

metricChange(KafkaMetric) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

This is called whenever a metric is updated or added

metricChange(KafkaMetric) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector

This is called whenever a metric is updated or added

metricChange(KafkaMetric) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

This is called whenever a metric is added/registered

metricKey(T) - Method in interface io.confluent.telemetry.collector.MetricNamingStrategy

Converts an implementation-specific metric name (e.g.

MetricKey - Class in io.confluent.telemetry

Value object that contains the name and labels for a Metric.

MetricKey(String, Map<String, String>) - Constructor for class io.confluent.telemetry.MetricKey

Create a MetricKey

MetricKey.Builder - Class in io.confluent.telemetry

MetricNamingStrategy<T> - Interface in io.confluent.telemetry.collector

metricRemoval(KafkaMetric) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

This is called whenever a metric is removed

metricRemoval(KafkaMetric) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector

This is called whenever a metric is removed

metricRemoval(KafkaMetric) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

This is called whenever a metric is removed

METRICS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

METRICS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

METRICS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

METRICS_INCLUDE_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

METRICS_INCLUDE_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

METRICS_INCLUDE_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

METRICS_REPORTER_PREFIX - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

MetricsCollector - Interface in io.confluent.telemetry.collector

MetricsCollectorTask - Class in io.confluent.telemetry

MetricsCollectorTask(Collection<MetricsCollector>, long, Emitter) - Constructor for class io.confluent.telemetry.MetricsCollectorTask

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.ControlCenterProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaClientProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaRestProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaServerProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KsqlProvider

metricsIncludeRegexDefault() - Method in interface io.confluent.telemetry.provider.Provider

The metrics include regular expression list used as a default value for this provider.

metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

MetricsUtils - Class in io.confluent.telemetry

MetricsUtils() - Constructor for class io.confluent.telemetry.MetricsUtils

N

name() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo

NAMED_CLIENT_CONFIGURED_DOC_WARNING - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

NAMESPACE - Static variable in class io.confluent.telemetry.HostResourceLabelProvider

NAMESPACE - Static variable in class io.confluent.telemetry.JavaRuntimeResourceLabelProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.ControlCenterProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaConnectProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaRestProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaServerProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaStreamsProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.KsqlProvider

NAMESPACE - Static variable in class io.confluent.telemetry.provider.SchemaRegistryProvider

NAMESPACE_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

NAMESPACE_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

newBuilder() - Static method in class io.confluent.telemetry.collector.JvmMetricsCollector

newBuilder() - Static method in class io.confluent.telemetry.collector.VolumeMetricsCollector

newBuilder() - Static method in class io.confluent.telemetry.collector.YammerMetricsCollector

newBuilder() - Static method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

newBuilder() - Static method in class io.confluent.telemetry.MetricKey

newBuilder(ConfluentTelemetryConfig) - Static method in class io.confluent.telemetry.collector.VolumeMetricsCollector

Create a new Builder using values from the ConfluentTelemetryConfig.

newBuilder(KafkaExporterConfig) - Static method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

Create a new Builder using values from the ConfluentTelemetryConfig.

nonRetryableError(Exception) - Static method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

Creates a result indicating a non-retryable error occurred.

noRetries() - Static method in class io.confluent.telemetry.config.remote.polling.RetryConfig

Creates a RetryConfig that results in no retries.

notEmptyString(Map<String, ?>, String) - Static method in class io.confluent.telemetry.provider.Utils

Validate that the map contains the key and the key is a non-empty string

notFound() - Static method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

Creates a result indicating that no configuration was found.

notNullOrEmpty(String) - Static method in class io.confluent.metrics.reporter.Utils

noUpdate() - Static method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

Creates a result indicating that the configuration has not changed since the last check.

nowInUTC() - Static method in class io.confluent.telemetry.MetricsUtils

nowInUTC(Clock) - Static method in class io.confluent.telemetry.MetricsUtils

O

onRemoteConfigurationReceived(RemoteConfiguration) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

onUpdate(ClusterResource) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter

onUpdate(ClusterResource) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

OpenTelemetryMetricsSerde - Class in io.confluent.telemetry.serde

OpenTelemetryMetricsSerde() - Constructor for class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

OpenTelemetryReporterSelfMetrics - Class in io.confluent.telemetry.metrics.otel

OpenTelemetry implementation of TelemetryReporterSelfMetrics.

OpenTelemetryReporterSelfMetrics(OpenTelemetry, Map<String, String>) - Constructor for class io.confluent.telemetry.metrics.otel.OpenTelemetryReporterSelfMetrics

P

parseDefaultEndpointFromEnv(KubernetesRemoteConfigurationConfig, String) - Static method in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationSource

parseEndpointFromEnv(KubernetesRemoteConfigurationConfig, String, String) - Static method in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationSource

parseType(Object) - Static method in class io.confluent.telemetry.exporter.ClientConfig

parseType(Object) - Static method in class io.confluent.telemetry.exporter.ExporterConfig

PATH_CONFIG - Static variable in class io.confluent.telemetry.config.remote.file.FileRemoteConfigConfiguration

PATH_DOC - Static variable in class io.confluent.telemetry.config.remote.file.FileRemoteConfigConfiguration

PollingRemoteConfigurationConfig - Class in io.confluent.telemetry.config.remote.polling

PollingRemoteConfigurationConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

PollingRemoteConfigurationConfig(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

Constructor for child classes

PollingRemoteConfigurationSource - Class in io.confluent.telemetry.config.remote.polling

PredicateUtils - Class in io.confluent.telemetry

PredicateUtils() - Constructor for class io.confluent.telemetry.PredicateUtils

PREFIX - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

PREFIX - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_API - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PREFIX_BUFFER - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PREFIX_CLIENT - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PREFIX_EXPORTER - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_EXPORTER_CLIENT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_LABELS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_METRICS_COLLECTOR - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_PRODUCER - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

PREFIX_PRODUCER - Static variable in class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

PREFIX_PROXY - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PREFIX_REMOTE_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

PREFIX_TOPIC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

PRODUCER_NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider

ProducerClientConfig - Class in io.confluent.telemetry.exporter.kafka

ProducerClientConfig(String, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.exporter.kafka.ProducerClientConfig

ProtoToJson - Class in io.confluent.telemetry.serde

ProtoToJson() - Constructor for class io.confluent.telemetry.serde.ProtoToJson

Provider - Interface in io.confluent.telemetry.provider

Implement this interface to collect metrics for your component.

ProviderRegistry - Class in io.confluent.telemetry.provider

ProviderRegistry() - Constructor for class io.confluent.telemetry.provider.ProviderRegistry

providers - Static variable in class io.confluent.telemetry.provider.ProviderRegistry

PROXY_PASSWORD - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_PASSWORD - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PROXY_PASSWORD_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_PASSWORD_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PROXY_URL - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_URL - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PROXY_URL_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_URL_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PROXY_USERNAME - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_USERNAME - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PROXY_USERNAME_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

PROXY_USERNAME_DOC - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

PUBLISH_PERIOD_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

PUBLISH_PERIOD_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

putIfNotNull(Map<String, String>, String, String) - Static method in class io.confluent.telemetry.emitter.ClientLabels

putLabel(String, String) - Method in class io.confluent.telemetry.MetricKey.Builder

putLabels(String...) - Method in class io.confluent.telemetry.MetricKey.Builder

putLabels(Map<String, String>) - Method in class io.confluent.telemetry.MetricKey.Builder

R

READ_TIMEOUT_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

READ_TIMEOUT_MS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesRemoteConfigurationConfig

reconcileConfigs(Map<String, ?>) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig

RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.exporter.http.HttpClientConfig

RECONFIGURABLE_CONFIGS - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

reconfigurableConfigs() - Method in class io.confluent.telemetry.reporter.TelemetryReporter

RECONFIGURABLES - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

RECONFIGURABLES - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.exporter.ClientConfig

Return a new ClientConfig by overriding this config with the provided Map.

reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

reconfigure(Map<String, ?>, Map<String, ClientConfig>) - Method in class io.confluent.telemetry.exporter.ExporterConfig

Return a new ExporterConfig by overriding this config with the provided Map.

reconfigurePredicate(Predicate<? super Keyed>) - Method in class io.confluent.telemetry.emitter.TelemetryEmitter

reconfigurePredicate(Predicate<Keyed>) - Method in class io.confluent.telemetry.exporter.AbstractExporter

Reconfigure the metrics predicate.

reconfigurePredicate(Predicate<Keyed>) - Method in interface io.confluent.telemetry.exporter.Exporter

Reconfigure the metrics predicate.

record(double) - Method in interface io.confluent.telemetry.metrics.SelfMetricsSensor

record(double, Map<String, String>) - Method in interface io.confluent.telemetry.metrics.SelfMetricsSensor

ReferenceTrackingProxy<R,T> - Class in io.confluent.telemetry.exporter

A proxy class that wraps a closeable resource and keeps track of the number of references to it.

REFRESH_INTERVAL_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

REFRESH_INTERVAL_MS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RegexConfigDefValidator - Class in io.confluent.telemetry

RegexConfigDefValidator(String) - Constructor for class io.confluent.telemetry.RegexConfigDefValidator

register(UUID) - Method in class io.confluent.telemetry.exporter.CloseableReferenceTracker

registerProvider(String, String) - Static method in class io.confluent.telemetry.provider.ProviderRegistry

REMOTE_CONFIG_CONFLUENT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

REMOTE_CONFIGURABLE_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

REMOTE_CONFIGURABLE_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

REMOTE_CONFIGURABLE_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

RemoteConfigConfiguration - Class in io.confluent.telemetry.config.remote

RemoteConfigConfiguration(ConfigDef, Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.RemoteConfigConfiguration

RemoteConfigurationSource - Interface in io.confluent.telemetry.config.remote

remove(MetricKey) - Method in class io.confluent.telemetry.collector.LastValueTracker

RequestConfigResult - Class in io.confluent.telemetry.config.remote.polling

Wrapper class that encapsulates the result of requesting remote configuration.

resolveOtlpClientBaseUrl(RemoteConfiguration) - Static method in class io.confluent.telemetry.exporter.http.HttpConfigUtils

Special handling for cloud deployments when "otlp" exporter is present in the remote config, but the CLIENT_BASE_URL property is missing.

resource() - Method in class io.confluent.telemetry.emitter.ContextExportableMetric

resource() - Method in interface io.confluent.telemetry.exporter.ExportableMetric

resource() - Method in class io.confluent.telemetry.provider.ControlCenterProvider

resource() - Method in class io.confluent.telemetry.provider.KafkaClientProvider

resource() - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

resource() - Method in class io.confluent.telemetry.provider.KafkaRestProvider

resource() - Method in class io.confluent.telemetry.provider.KafkaServerProvider

resource() - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

resource() - Method in class io.confluent.telemetry.provider.KsqlProvider

resource() - Method in interface io.confluent.telemetry.provider.Provider

The resource for this provider.

resource() - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

RESOURCE_LABEL_CLUSTER_ID - Static variable in class io.confluent.telemetry.provider.Utils

ResourceBuilderFacade - Class in io.confluent.telemetry

A wrapper on the protobuf Resource.Builder that enforces Confluent conventions.

ResourceBuilderFacade(String) - Constructor for class io.confluent.telemetry.ResourceBuilderFacade

ResourceLabelProvider - Interface in io.confluent.telemetry

Provides labels from the runtime context (Cloud, Deployment, Host, JVM, etc) that can be set on the Resource.

resourceMetrics() - Method in class io.confluent.telemetry.emitter.ClientExportableMetric

resourceMetrics() - Method in class io.confluent.telemetry.emitter.ContextExportableMetric

resourceMetrics() - Method in interface io.confluent.telemetry.exporter.ExportableMetric

RETRY_BACKOFF_MULTIPLIER_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RETRY_BACKOFF_MULTIPLIER_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RETRY_INITIAL_DELAY_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RETRY_INITIAL_DELAY_MS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RETRY_MAX_DELAY_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

RETRY_MAX_DELAY_MS_DOC - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

retryableError(Exception) - Static method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

Creates a result indicating a retryable error occurred.

RetryConfig - Class in io.confluent.telemetry.config.remote.polling

Configuration for retry behavior with exponential backoff.

RetryHandler - Class in io.confluent.telemetry.config.remote.polling

Handles retry logic with exponential backoff for remote configuration requests.

RetryHandler() - Constructor for class io.confluent.telemetry.config.remote.polling.RetryHandler

S

SchemaRegistryProvider - Class in io.confluent.telemetry.provider

SchemaRegistryProvider() - Constructor for class io.confluent.telemetry.provider.SchemaRegistryProvider

SCHEMAS_TOPIC_CONFIG - Static variable in class io.confluent.telemetry.provider.SchemaRegistryProvider

SELF_METRICS_DOMAIN - Static variable in class io.confluent.telemetry.reporter.TelemetryReporter

SELF_METRICS_GROUP - Static variable in class io.confluent.telemetry.exporter.http.HttpExporter

SELF_METRICS_NAMESPACE - Static variable in class io.confluent.telemetry.reporter.TelemetryReporter

SelfMetricsSensor - Interface in io.confluent.telemetry.metrics

A sensor for recording self-metric values with optional tags.

serialize(String, MetricsData) - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

serializer() - Method in class io.confluent.telemetry.serde.OpenTelemetryMetricsSerde

setAdminClientProperties(Properties) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setAggregationRules(Set<AggregationRule>) - Method in class io.confluent.telemetry.MetricsCollectorTask

setClock(Clock) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

setConfig(R) - Method in class io.confluent.telemetry.exporter.CloseableReferenceTracker

setConfigurationChangeCallback(Consumer<RemoteConfiguration>) - Method in class io.confluent.telemetry.config.remote.file.FileRemoteConfigSource

setConfigurationChangeCallback(Consumer<RemoteConfiguration>) - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

Only one callback can be registered.

setConfigurationChangeCallback(Consumer<RemoteConfiguration>) - Method in interface io.confluent.telemetry.config.remote.RemoteConfigurationSource

Registers a callback to be called when the remote configuration has changed

setContext(Context) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector.Builder

setContext(Context) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder

setCreateTopic(boolean) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setCredentials(Credentials) - Method in class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

setDoubleDeltas(LastValueTracker<Double>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

setDynamicFields(HttpExporterConfig) - Method in class io.confluent.telemetry.exporter.http.HttpExporter

setLogDirs(String[]) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder

setLongDeltas(LastValueTracker<Long>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

setMetricNamingStrategy(MetricNamingStrategy<MetricName>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

setMetricsPredicate(Predicate<Keyed>) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setMetricsRegistry(MetricsRegistry) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder

setMetricsRegistry(Metrics) - Method in interface io.confluent.telemetry.exporter.Exporter

Set the Metrics registry on this Exporter.

setMetricsRegistry(Metrics) - Method in class io.confluent.telemetry.exporter.http.HttpExporter

setMetricsRegistry(Metrics) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter

Sets the Metrics registry for this exporter.

setName(String) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setName(String) - Method in class io.confluent.telemetry.MetricKey.Builder

setProducer(Producer<byte[], MetricsData>) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setProxyConfig(ProxyConfig) - Method in class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

setTopicConfig(Map<String, String>) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setTopicName(String) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setTopicPartitions(int) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setTopicReplicas(int) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder

setUpdatePeriodMs(long) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder

SharedJvmMetricsCollector - Class in io.confluent.telemetry.collector

A wrapper around JvmMetricsCollector that ensures only one collector instance exists per JVM process, even when multiple TelemetryReporter instances are running.

SharedJvmMetricsCollector(Context) - Constructor for class io.confluent.telemetry.collector.SharedJvmMetricsCollector

shouldEmitMetric(Keyed) - Method in class io.confluent.telemetry.emitter.AggregatingEmitter

shouldEmitMetric(Keyed) - Method in interface io.confluent.telemetry.emitter.Emitter

Tests whether this metric object could actually be emitted based on its key.

shouldEmitMetric(Keyed) - Method in class io.confluent.telemetry.emitter.TelemetryEmitter

SinglePointMetric - Class in io.confluent.telemetry.metrics

An OpenTelemetry (unbuilt) Metric and its associated MetricKey.

SLO_COLLECTOR_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

SLO_COLLECTOR_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

SLOMetricsCollector - Class in io.confluent.telemetry.collector

A MetricsCollector that ensures exactly one metric will be exported per minute by oversampling the metric source every 30 seconds.

SLOMetricsCollector(MetricsRegistry, MetricNamingStrategy<MetricName>) - Constructor for class io.confluent.telemetry.collector.SLOMetricsCollector

sslConfigs() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig

SslFactory - Class in io.confluent.telemetry.exporter.http

SslFactory(Map<String, Object>) - Constructor for class io.confluent.telemetry.exporter.http.SslFactory

start() - Method in interface io.confluent.telemetry.collector.MetricsCollector

start() - Method in class io.confluent.telemetry.collector.SLOMetricsCollector

start() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

start() - Method in interface io.confluent.telemetry.config.remote.RemoteConfigurationSource

start() - Method in class io.confluent.telemetry.MetricsCollectorTask

stop() - Method in interface io.confluent.telemetry.collector.MetricsCollector

stop() - Method in class io.confluent.telemetry.collector.SharedJvmMetricsCollector

stop() - Method in class io.confluent.telemetry.collector.SLOMetricsCollector

stop() - Method in class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

stop() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

stop() - Method in interface io.confluent.telemetry.config.remote.RemoteConfigurationSource

STREAMS_APPLICATION_ID - Static variable in class io.confluent.telemetry.provider.KafkaStreamsProvider

subset(Set<String>) - Method in class io.confluent.telemetry.config.FilterSetPredicate

Returns a new FilterSetPredicate containing only the NamedFilters with the given names.

success(RemoteConfiguration) - Static method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

Creates a successful result with the retrieved configuration.

SYSTEM_DOMAIN - Static variable in class io.confluent.telemetry.collector.JvmMetricsCollector

T

TELEMETRY_API_KEY - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

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

TELEMETRY_API_KEY_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_API_SECRET - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_API_SECRET_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_CONFLUENT_CLOUD_URL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_ENABLED_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_ENABLED_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_EXTERNAL_CLIENT_METRICS_EXCLUDE_LABELS_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_PASSWORD - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_PASSWORD_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_URL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_URL_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_USERNAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_PROXY_USERNAME_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

TELEMETRY_REPORTER_ID_TAG - Static variable in class io.confluent.telemetry.reporter.TelemetryReporter

TelemetryEmitter - Class in io.confluent.telemetry.emitter

Must construct after 1.

TelemetryEmitter(Context, Supplier<Collection<Exporter>>, Metrics) - Constructor for class io.confluent.telemetry.emitter.TelemetryEmitter

TelemetryReporter - Class in io.confluent.telemetry.reporter

TelemetryReporter() - Constructor for class io.confluent.telemetry.reporter.TelemetryReporter

TelemetryReporter(EventLoggerFactory) - Constructor for class io.confluent.telemetry.reporter.TelemetryReporter

TelemetryReporterSelfMetrics - Interface in io.confluent.telemetry.metrics

Simple metrics abstraction for Telemetry Reporter self-metrics.

test(Keyed) - Method in class io.confluent.telemetry.config.FilterSetPredicate

We avoid the streams abstraction here for performance reasons since this will be called on every metric for every predicate.

timer(double, String, Map<String, String>) - Method in class io.confluent.logredactor.KafkaSensorLogRedactorMetrics

timers - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult

toBuilder() - Method in class io.confluent.telemetry.MetricKey

TOPIC_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_CREATE_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_CREATE_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_CREATE_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_CREATE_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_MAX_MESSAGE_BYTES_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_MAX_MESSAGE_BYTES_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_MAX_MESSAGE_BYTES_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_MAX_MESSAGE_BYTES_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_NAME_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_NAME_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_PARTITIONS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_PARTITIONS_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_PARTITIONS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_REPLICAS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_REPLICAS_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_REPLICAS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_RETENTION_BYTES_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_BYTES_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_RETENTION_BYTES_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_RETENTION_MS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_RETENTION_MS_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_RETENTION_MS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_ROLL_MS_CONFIG - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

TOPIC_ROLL_MS_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

TOPIC_ROLL_MS_DOC - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

toString() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo

toString() - Method in class io.confluent.telemetry.collector.JvmMetricsCollector

toString() - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector

toString() - Method in class io.confluent.telemetry.collector.SharedJvmMetricsCollector

toString() - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector

toString() - Method in class io.confluent.telemetry.collector.YammerMetricsCollector

toString() - Method in class io.confluent.telemetry.config.remote.polling.RequestConfigResult

toString() - Method in class io.confluent.telemetry.config.remote.polling.RetryConfig

toString() - Method in class io.confluent.telemetry.MetricKey

totalBytes() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo

toTimeUnixNanos(Instant) - Static method in class io.confluent.telemetry.MetricsUtils

translate(Map<String, T>) - Method in class io.confluent.telemetry.ConfigPropertyTranslater

Return a new Map by applying the configured translations to each key.

translateDeprecated(Map<String, T>, String[][]) - Static method in class io.confluent.telemetry.common.config.ConfigUtils

TYPE_CONFIG - Static variable in class io.confluent.telemetry.exporter.ClientConfig

TYPE_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

TYPE_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ClientConfig

TYPE_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig

U

union(FilterSetPredicate) - Method in class io.confluent.telemetry.config.FilterSetPredicate

Creates a new FilterSetPredicate containing all the NamedFilters from this object, plus any NamedFilters from the other set that is not contained the current NamedFilterSet.

unregister(UUID) - Method in class io.confluent.telemetry.exporter.CloseableReferenceTracker

updateClientConfigs(String, Map<String, ?>) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

updateExporterConfigs(String, Map<String, ?>) - Method in class io.confluent.telemetry.ConfluentTelemetryConfig

URIValidator() - Constructor for class io.confluent.telemetry.exporter.http.HttpConfigUtils.URIValidator

usableBytes() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo

Utils - Class in io.confluent.metrics.reporter

Utils - Class in io.confluent.telemetry.provider

Utils() - Constructor for class io.confluent.telemetry.provider.Utils

V

V1_CONFIGURATION_ENDPOINT - Static variable in class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

V1_HEADER_BYTES - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporter

V1Object - Class in io.confluent.telemetry.config.remote.polling.kubernetes

Custom object for Kubernetes objects such as V1Secret or V1ConfigMap We define the fields we need here instead of pulling all K8s APIs to keep the size of the `ce-metrics` jar small

V1Object(String, Map<String, String>, V1ObjectMeta) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.V1Object

V1ObjectMeta - Class in io.confluent.telemetry.config.remote.polling.kubernetes

V1ObjectMeta(String, String, String) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.V1ObjectMeta

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.ControlCenterProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaClientProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaRestProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaServerProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.KsqlProvider

validate(MetricsContext, Map<String, ?>) - Method in interface io.confluent.telemetry.provider.Provider

Validate that all the data required for generating correct metrics is present.

validate(MetricsContext, Map<String, ?>) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider

validateReconfiguration(Map<String, ?>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter

validateRequiredLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils

Validate that the MetricsContext metadata has tags for - _namespace - type - version - cluster id

validateRequiredResourceLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils

valueOf(String) - Static method in enum class io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.telemetry.exporter.ExporterConfig.ExporterType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.telemetry.exporter.ExporterConfig.ExporterType

Returns an array containing the constants of this enum class, in the order they are declared.

VERSION_HEADER_KEY - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporter

VOLUME_LABEL - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector

VOLUME_METRICS_REFRESH_PERIOD_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

VOLUME_METRICS_REFRESH_PERIOD_MS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

VOLUME_METRICS_UPDATE_PERIOD_DOC - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

VOLUME_METRICS_UPDATE_PERIOD_MS - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

VolumeMetricsCollector - Class in io.confluent.telemetry.collector

VolumeMetricsCollector.Builder - Class in io.confluent.telemetry.collector

VolumeMetricsCollector.VolumeMetricsCollectorConfig - Class in io.confluent.telemetry.collector

VolumeMetricsCollectorConfig(Map<?, ?>) - Constructor for class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

VolumeMetricsCollectorConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig

VolumeMetricsProvider - Class in io.confluent.metrics.reporter

VolumeMetricsProvider(long, String[]) - Constructor for class io.confluent.metrics.reporter.VolumeMetricsProvider

Create a volume metrics provider.

VolumeMetricsProvider.VolumeInfo - Class in io.confluent.metrics.reporter

W

withId(String) - Method in class io.confluent.telemetry.ResourceBuilderFacade

withLabel(String, String) - Method in class io.confluent.telemetry.ResourceBuilderFacade

Add a label to this Resource.

withLabel(String, List<String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade

withLabels(Map<String, String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade

Add labels to this Resource.

withNamespacedLabel(String, String) - Method in class io.confluent.telemetry.ResourceBuilderFacade

Add a label to this Resource, prefixed with this Resource's type.

withNamespacedLabel(String, List<String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade

withNamespacedLabels(Map<String, String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade

Add labels to this Resource, prefixed with this Resource's type.

withPrefixTranslation(String, String) - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder

Add a prefix translation.

withTranslation(String, String) - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder

Add a property translation.

withVersion(String) - Method in class io.confluent.telemetry.ResourceBuilderFacade

writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter

Y

YAMMER_METRICS_LIB - Static variable in class io.confluent.telemetry.collector.ConfluentMetricNamingConvention

YammerMetricsCollector - Class in io.confluent.telemetry.collector

YammerMetricsCollector(MetricsRegistry, MetricNamingStrategy<MetricName>, LastValueTracker<Long>, LastValueTracker<Double>, Clock) - Constructor for class io.confluent.telemetry.collector.YammerMetricsCollector

YammerMetricsCollector.Builder - Class in io.confluent.telemetry.collector

YammerMetricsHelper - Class in io.confluent.metrics.reporter

YammerMetricsHelper() - Constructor for class io.confluent.metrics.reporter.YammerMetricsHelper

YammerMetricsHelper.YammerMetricsResult - Class in io.confluent.metrics.reporter

YammerMetricsResult(List<ConfluentMetric.YammerGauge>, List<ConfluentMetric.YammerMeter>, List<ConfluentMetric.YammerHistogram>, List<ConfluentMetric.YammerTimer>) - Constructor for class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values