- canEmitMetrics - Variable in class io.confluent.telemetry.exporter.http.HttpExporter
-
- canEmitMetrics() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
-
- cleanLabelNames(Map<String, String>) - Static method in class io.confluent.telemetry.MetricsUtils
-
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
-
- 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.collector.KafkaMetricsCollector.StateLedger
-
- 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(Exporter) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector
-
- collect(Exporter) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector
-
- collect(Exporter) - Method in interface io.confluent.telemetry.collector.MetricsCollector
-
- collect(Exporter) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector
-
- collect(Exporter) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector
-
- collect(Exporter) - Method in class io.confluent.telemetry.MetricsCollectorTask
-
- 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
-
- collector(Predicate<MetricKey>, Context) - Method in interface io.confluent.telemetry.collector.MetricsCollectorProvider
-
- collector(Predicate<MetricKey>, Context) - Method in class io.confluent.telemetry.exporter.http.HttpExporter
-
- collector(Predicate<MetricKey>, Context) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter
-
- 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, 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.ConfluentMetricsReporter
-
Configure this class with the given key-value pairs
- configure(Map<String, ?>) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
-
- 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
-
- ConfigUtils - Class in io.confluent.telemetry.common.config
-
- ConfigUtils() - Constructor for class io.confluent.telemetry.common.config.ConfigUtils
-
- 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
-
- 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
-
- Context(Resource, String, boolean, 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.MetricsUtils
-
Converts a tag/name to match the telemetry naming conventions by converting snake_case.