A B C D E F G H I J K L M N O P R S T U V W Y

A

AbstractExporter - Class in io.confluent.telemetry.exporter

AbstractExporter(Context) - Constructor for class io.confluent.telemetry.exporter.AbstractExporter

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

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

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

allExportersWithNames(Set<String>) - 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.HttpExporterConfig

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

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

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.HttpExporterConfig

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.HttpExporterConfig

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.HttpExporterConfig

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.HttpExporterConfig

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(Metric) - Method in class io.confluent.telemetry.Context

Build a MetricsData containing a single Metric.

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

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

buildRequest(Iterable<Metric>) - Method in class io.confluent.telemetry.Context

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

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

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.HttpExporterConfig

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.HttpExporterConfig

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

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.HttpExporterConfig

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

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

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.HttpExporterConfig

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.HttpExporterConfig

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.kafka.KafkaExporterConfig

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

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

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.HttpExporterConfig

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.HttpExporterConfig

ClientConfig - Class in io.confluent.telemetry.exporter

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

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

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

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

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.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.KubernetesConfigMapRemoteConfigurationConfig

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

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.HttpExporterConfig

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

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

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

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

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(String) - Constructor for class io.confluent.telemetry.Context

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

Context(Resource, String, boolean) - 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

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

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

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

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

cumulativeSum(MetricKey, double, 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_COLLECT_INTERVAL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

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

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

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_NAMED_FILTER_NAME - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig

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

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

DEFAULT_REFRESH_INTERVAL - 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_SUBSET_PARTITIONER_ENABLED - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

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

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, long, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

deltaSum(MetricKey, double, 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(ExportableMetric) - Method in class io.confluent.telemetry.exporter.AbstractExporter

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Domain of the active provider.

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

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

E

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

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

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 - Interface in io.confluent.telemetry.emitter

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

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.HttpExporterConfig.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.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

ExportableMetric - Class in io.confluent.telemetry.emitter

Exporter - Interface in io.confluent.telemetry.exporter

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 in io.confluent.telemetry.exporter

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

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

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.

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

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

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

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, Number, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric

creates a metric data point for arbitrary Number values.

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

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

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

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

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

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

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

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

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

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

Get the compression algorithm.

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

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.HttpExporterConfig

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

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

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

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

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

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

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 io.opencensus.proto.resource.v1.Resource.

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

getMetric() - Method in class io.confluent.telemetry.emitter.ExportableMetric

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

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

getMetricsData() - Method in class io.confluent.telemetry.emitter.ExportableMetric

Construct a MetricsData by binding the underlying Metric to the Resource from the Context.

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

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

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

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

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

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(boolean, 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.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

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

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

H

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.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

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

HttpExporter(Context, 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.URIValidator - 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

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

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.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.Context

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

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

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

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

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_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, ?>, 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

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.ExportableMetric

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

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

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

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

This RemoteConfigurationSource will continuously poll the Kubernetes API for a ConfigMap containing the RemoteConfiguration object.

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

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

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.

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.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_ALIAS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig

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

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

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.KubernetesConfigMapRemoteConfigurationConfig

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

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

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

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

Create a new Builder using values from the ConfluentTelemetryConfig.

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

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

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

Create a new Builder using values from the ConfluentTelemetryConfig.

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

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

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

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

nowInUTC() - 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

P

parseDefaultEndpointFromEnv(KubernetesConfigMapRemoteConfigurationConfig) - Static method in class io.confluent.telemetry.config.remote.polling.kubernetes.KubernetesConfigMapRemoteConfigurationSource

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

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

PollingRemoteConfigurationSource(long, Consumer<RemoteConfiguration>) - Constructor for class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

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_BUFFER - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig

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

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.HttpExporterConfig

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.HttpExporterConfig

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

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

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

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

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

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

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

R

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

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.ExporterConfig

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

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

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.

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

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

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

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 io.opencensus.proto.resource.v1.Resource.

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

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

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

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

setContext(Context) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.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

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

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

setProducer(KafkaProducer<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

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

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.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.

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

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

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

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

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_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_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

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.VolumeMetricsCollector

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

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.

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

URIValidator() - Constructor for class io.confluent.telemetry.exporter.http.HttpExporterConfig.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

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

Custom object for Kubernetes V1ConfigMap We define the fields we need here instead of pulling all K8s APIs to keep the size of the `ce-metrics` jar small

V1ConfigMap(Map<String, String>, V1ObjectMeta) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.V1ConfigMap

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 io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.confluent.telemetry.exporter.ExporterConfig.ExporterType

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.confluent.telemetry.exporter.ClientConfig.ClientConfigType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.confluent.telemetry.exporter.ExporterConfig.ExporterType

Returns an array containing the constants of this enum type, 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