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

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

addSinglePointTimeseries(Point) - Method in class io.confluent.telemetry.MetricBuilderFacade

Add a TimeSeries containing a single Point.

addSinglePointTimeseries(Point, Timestamp) - Method in class io.confluent.telemetry.MetricBuilderFacade

Add a TimeSeries containing a single Point and the given startTimestamp.

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

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

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

Build the Metric.

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

buildMetric(Metric) - Method in class io.confluent.telemetry.Context

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

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

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

clone() - Method in class io.confluent.telemetry.MetricBuilderFacade

Perform a deep clone of this builder.

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

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

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

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

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_DEF - Static variable in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationConfig

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

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

ConfigSet(Set<ConfigSet.ConfigSetEntry>) - Constructor for class io.confluent.telemetry.config.remote.polling.kubernetes.ConfigSet

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, boolean) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto

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

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

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

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

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

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

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

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

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

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

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

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

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

doEmit(SerializedMetric) - 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(SerializedMetric) - Method in class io.confluent.telemetry.exporter.AbstractExporter

emit(SerializedMetric) - 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.config.remote.polling.kubernetes.ConfigSet

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

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(ConfigDef, Map<?, ?>) - Constructor for class io.confluent.telemetry.exporter.ExporterConfig

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

FilterSetPredicate - Class in io.confluent.telemetry.config

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

FilterSetPredicate(NamedFilter) - Constructor for class io.confluent.telemetry.config.FilterSetPredicate

FilterSetPredicate(Set<NamedFilter>) - Constructor for class io.confluent.telemetry.config.FilterSetPredicate

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

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

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

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

getCompatibleConfigVersion(String) - Method in class io.confluent.telemetry.config.remote.polling.kubernetes.ConfigSet

The ConfigMap will hold 1 remote configuration objects for each major API schema version.

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

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

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

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

Get labels to be set on the Resource.

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

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

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

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

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

H

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

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

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

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

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

Configuration for the HttpExporter.

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

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

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

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

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

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(Map<String, ?>) - Constructor for class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig

KafkaExporterConfig(Map<String, ?>, 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.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.SerializedMetric

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

KubernetesConfigMapRemoteConfigurationSource(KubernetesConfigMapRemoteConfigurationConfig, 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

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

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

MetricBuilderFacade - Class in io.confluent.telemetry

A wrapper on the protobuf Metric.Builder that provides: A simpler interface for applying labels as a flat set of key-value pairs Convenience methods for building a TimeSeries containing a single Point Enforcement of Confluent conventions

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

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

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

metricsData() - Method in class io.confluent.telemetry.metrics.SerializedMetric

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.

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

OpencensusMetricsProto - Class in io.confluent.telemetry.serde

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

OpenTelemetryMetricsSerde - Class in io.confluent.telemetry.serde

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

P

parseConfigYaml(String) - Static method in class io.confluent.telemetry.config.remote.polling.kubernetes.ConfigSet

We need to provide this convoluted way of parsing configs returned from the ConfigMap because k8s only allows us to specify ConfigMaps of Map so we're unable to interpret the yaml directly.

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

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

ProtoToFlatJson - Class in io.confluent.telemetry.serde

Implements a Deserializer that flattens the Metric (assuming one point and one time series) before writing it out a JSON string.

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

ProtoToFlatJson(boolean) - Constructor for class io.confluent.telemetry.serde.ProtoToFlatJson

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

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

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

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

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 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, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto

serialize(String, Headers, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto

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

SerializedMetric - Class in io.confluent.telemetry.metrics

In contrast to @{link io.confluent.telemetry.metrics.SinglePointMetric}, this is an internal class that represents a metric that contains resource labels and is ready to be handed off to the @link{io.confluent.telemetry.exporter.Exporter} objects.

SerializedMetric(ResourceMetrics, MetricKey) - Constructor for class io.confluent.telemetry.metrics.SerializedMetric

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

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

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

setProducerProperties(Properties) - 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

This class represents a metric that does not yet contain resource labels.

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

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

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

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

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

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

toInstant(Timestamp) - Static method in class io.confluent.telemetry.serde.ProtoToFlatJson

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

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.

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

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

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

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

withLabels(Map<String, String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade

Add labels to this Resource.

withName(String) - Method in class io.confluent.telemetry.MetricBuilderFacade

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.

withResource(Resource) - Method in class io.confluent.telemetry.MetricBuilderFacade

withTranslation(String, String) - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder

Add a property translation.

withType(MetricDescriptor.Type) - Method in class io.confluent.telemetry.MetricBuilderFacade

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