Skip navigation links
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
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 
Skip navigation links