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

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.config.remote.polling.RemoteConfigurationRequest.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.config.remote.polling.RemoteConfigurationRequest.Builder
 
Builder() - Constructor for class io.confluent.telemetry.ConfigPropertyTranslater.Builder
 
buildMetric(MetricBuilderFacade) - Method in class io.confluent.telemetry.Context
Set the context for MetricBuilderFacade and build a Metric
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_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.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_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
 
configEvent(Map<String, ?>, Predicate<String>, Resource, Provider, String) - Static method in class io.confluent.telemetry.provider.Utils
 
configInclude() - Method in class io.confluent.telemetry.provider.KafkaServerProvider
 
configInclude() - Method in interface io.confluent.telemetry.provider.Provider
Include list for config
configPredicate(String) - Static method in class io.confluent.telemetry.provider.Utils
 
ConfigPropertyTranslater - Class in io.confluent.telemetry
Translates map keys according to configured rules.
ConfigPropertyTranslater.Builder - Class in io.confluent.telemetry
 
configure(Map<String, ?>) - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter
 
configure(Map<String, ?>) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter
Configure this class with the given key-value pairs
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.ControlCenterProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaClientProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaRestProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaServerProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.KsqlProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider
 
configure(Map<String, ?>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter
Note: we are assuming that these methods are invoked in the following order: 1.
configure(Map, boolean) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
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.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
 
counter(MetricKey, long, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric
 
counter(MetricKey, long, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric
 
counter(MetricKey, double, Instant, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric
 
counter(MetricKey, double, Instant) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric
 
CPU_METRIC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
create(MetricKey, MetricDescriptor.Type, Point, Timestamp) - Static method in class io.confluent.telemetry.metrics.SinglePointMetric
 
create(MetricKey, MetricDescriptor.Type, Point) - 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.config.remote.RemoteConfigConfiguration
 
DEFAULT_COLLECT_INTERVAL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_ENABLED_CONFIG - 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_PUBLISH_PERIOD - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
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
 
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.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
 
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.NamedFilter
 
equals(Object) - Method in class io.confluent.telemetry.config.NamedFilterSet
 
equals(Object) - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationResponse
 
equals(Object) - Method in class io.confluent.telemetry.config.remote.RemoteConfiguration
 
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

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, 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
 
getActiveFilters() - Method in class io.confluent.telemetry.config.remote.RemoteConfiguration
 
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
 
getChecksum() - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationResponse
 
getCollectors() - Method in class io.confluent.telemetry.reporter.TelemetryReporter
 
getCompressionAlgorithm(String) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
Get the compression algorithm.
getConfig() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource
 
getConfig() - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationResponse
 
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
 
getDefaultFilterSet() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
getDomain() - Method in class io.confluent.telemetry.Context
 
getFilters() - Method in class io.confluent.telemetry.config.remote.RemoteConfiguration
 
getInclude() - Method in class io.confluent.telemetry.config.NamedFilter
 
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.
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.NamedFilter
 
getName() - Method in class io.confluent.telemetry.MetricKey
 
getNonResourceLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils
 
getPredicate() - Method in class io.confluent.telemetry.config.NamedFilter
 
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.RemoteConfigConfiguration
 
getRemoteConfigConfiguration() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
getResource() - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationRequest
 
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.
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.NamedFilter
 
hashCode() - Method in class io.confluent.telemetry.config.NamedFilterSet
 
hashCode() - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationResponse
 
hashCode() - Method in class io.confluent.telemetry.config.remote.RemoteConfiguration
 
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, 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
 
injectProviderConfigs(Provider, Map<String, Object>) - Static method in class io.confluent.telemetry.reporter.TelemetryReporter
 
InstantAndValue(Instant, T) - Constructor for class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue
 
INTER_BROKER_LISTENER_NAME_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
INTER_BROKER_LISTENER_NAME_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
INTER_BROKER_SECURITY_PROTOCOL_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
INTER_BROKER_SECURITY_PROTOCOL_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
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.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.NamedFilterSet
 
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_CLUSTER_ID - 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
 
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
 

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_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_COLLECTOR - Static variable in interface io.confluent.telemetry.collector.MetricsCollector
Label for the collector that collected the metrics
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
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
LISTENER_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
LISTENER_SECURITY_PROTOCOL_MAP_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
LISTENERS_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
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
 
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
metricReportRunnable() - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter
 
METRICS_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
METRICS_ENABLED_CONFIG_DEFAULT - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
METRICS_ENABLED_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
METRICS_INCLUDE_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
METRICS_INCLUDE_CONFIG_ALIAS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
METRICS_INCLUDE_CONFIG_ALIAS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
METRICS_INCLUDE_CONFIG_DOC - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
METRICS_INCLUDE_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
METRICS_INCLUDE_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
METRICS_REPORTER_PREFIX - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
MetricsCollector - Interface in io.confluent.telemetry.collector
 
MetricsCollectorTask - Class in io.confluent.telemetry
 
MetricsCollectorTask(Collection<MetricsCollector>, long, Emitter) - Constructor for class io.confluent.telemetry.MetricsCollectorTask
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.ControlCenterProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaClientProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaConnectProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaRestProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaServerProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider
 
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.KsqlProvider
 
metricsIncludeRegexDefault() - Method in interface io.confluent.telemetry.provider.Provider
The metrics include regular expression list used as a default value for this provider.
metricsIncludeRegexDefault() - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider
 
MetricsUtils - Class in io.confluent.telemetry
 
MetricsUtils() - Constructor for class io.confluent.telemetry.MetricsUtils
 

N

name() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo
 
NamedFilter - Class in io.confluent.telemetry.config
A NamedFilter encapsulate the metrics' filtering criteria independent of usage in any Exporter.
NamedFilter(String, String) - Constructor for class io.confluent.telemetry.config.NamedFilter
 
NamedFilterSet - Class in io.confluent.telemetry.config
A grouping of unique NamedFilters to be applied to an Exporter.
NamedFilterSet(NamedFilter) - Constructor for class io.confluent.telemetry.config.NamedFilterSet
 
NamedFilterSet(Set<NamedFilter>) - Constructor for class io.confluent.telemetry.config.NamedFilterSet
 
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
 
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
 
now(Clock) - Static method in class io.confluent.telemetry.MetricsUtils
 
now() - Static method in class io.confluent.telemetry.MetricsUtils
 
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
 

P

parseType(Object) - Static method in class io.confluent.telemetry.exporter.ExporterConfig
 
POLLING_REFRESH_INTERVAL_MS_CONFIG - Static variable in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration
 
PollingRemoteConfigurationSource - Class in io.confluent.telemetry.config.remote.polling
 
PollingRemoteConfigurationSource(long) - 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

RACK_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
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_DOC - Static variable in class io.confluent.telemetry.config.remote.RemoteConfigConfiguration
 
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
 
RemoteConfigConfiguration - Class in io.confluent.telemetry.config.remote
 
RemoteConfigConfiguration(Map<?, ?>, boolean) - Constructor for class io.confluent.telemetry.config.remote.RemoteConfigConfiguration
 
RemoteConfiguration - Class in io.confluent.telemetry.config.remote
 
RemoteConfiguration() - Constructor for class io.confluent.telemetry.config.remote.RemoteConfiguration
 
RemoteConfiguration(Set<NamedFilter>, Set<String>) - Constructor for class io.confluent.telemetry.config.remote.RemoteConfiguration
 
RemoteConfigurationRequest - Class in io.confluent.telemetry.config.remote.polling
 
RemoteConfigurationRequest.Builder - Class in io.confluent.telemetry.config.remote.polling
 
RemoteConfigurationResponse - Class in io.confluent.telemetry.config.remote.polling
 
RemoteConfigurationResponse(String, RemoteConfiguration) - Constructor for class io.confluent.telemetry.config.remote.polling.RemoteConfigurationResponse
 
RemoteConfigurationSource - Interface in io.confluent.telemetry.config.remote
 
remove(MetricKey) - Method in class io.confluent.telemetry.collector.LastValueTracker
 
requestConfig() - Method in class io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource
 
requestConfig() - Method in class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource
 
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(Context) - Method in class io.confluent.telemetry.metrics.SinglePointMetric
 
serialize(String, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
serialize(String, Headers, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
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(Metric, MetricKey) - Constructor for class io.confluent.telemetry.metrics.SerializedMetric
 
serializer() - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
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.NamedFilterSet
Returns a new NamedFilterSet 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
 
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
 
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.NamedFilterSet
 
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.MetricsUtils
 
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
 
toTimestamp(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(NamedFilterSet) - Method in class io.confluent.telemetry.config.NamedFilterSet
Creates a new NamedFilterSet containing all the NamedFilters from this object, plus any NamedFilters from the other set that is not contained the current NamedFilterSet.
URI_PARSE_REGEX_STRING - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
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

V0_HEADER_BYTES - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporter
 
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.
withLabelAliases(Map<String, String>) - Method in class io.confluent.telemetry.ResourceBuilderFacade
Add label aliases.
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.
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
 
withResourceAttributes(Map<String, String>) - Method in class io.confluent.telemetry.config.remote.polling.RemoteConfigurationRequest.Builder
 
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