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
 
ADMIN_NAMESPACE - Static variable in class io.confluent.telemetry.provider.KafkaClientProvider
 
ADVERTISED_HOST_NAME_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
ADVERTISED_LISTENERS_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
ADVERTISED_PORT_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_TRUE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
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.KafkaMetricsCollector.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
 
Builder() - Constructor for class io.confluent.telemetry.ConfigPropertyTranslater.Builder
 
buildMetricsPredicate() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
buildMetricsPredicate(String) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
buildMetricsPredicate() - Method in class io.confluent.telemetry.exporter.ExporterConfig
 
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 - 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.

D

DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEBUG_ENABLED_DOC - 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_METRICS_INCLUDE - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
DEFAULT_METRICS_INCLUDE - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_METRICS_INCLUDE - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
DEFAULT_MIN_ISR - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
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_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
 
delta(MetricName, Instant, Double) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
 
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(MetricKey, Metric) - Method in class io.confluent.telemetry.exporter.AbstractExporter
 
doEmit(MetricKey, Metric) - Method in interface io.confluent.telemetry.exporter.Exporter
 
doEmit(MetricKey, Metric) - Method in class io.confluent.telemetry.exporter.http.HttpExporter
 
doEmit(MetricKey, Metric) - 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(MetricKey, Metric) - Method in class io.confluent.telemetry.exporter.AbstractExporter
 
emit(MetricKey, Metric) - Method in interface io.confluent.telemetry.exporter.Exporter
 
EMPTY_STRING - Static variable in class io.confluent.metrics.reporter.Utils
 
ENABLED_CONFIG - Static variable in class io.confluent.telemetry.exporter.ExporterConfig
 
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.MetricKey
 
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, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.ControlCenterProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KafkaClientProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KafkaConnectProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KafkaRestProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KafkaServerProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KafkaStreamsProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.KsqlProvider
 
extraCollectors(Context, Predicate<MetricKey>) - Method in interface io.confluent.telemetry.provider.Provider
The collector for Kafka Metrics library is enabled by default.
extraCollectors(Context, Predicate<MetricKey>) - Method in class io.confluent.telemetry.provider.SchemaRegistryProvider
 

F

fullMetricName(String, String, String) - Static method in class io.confluent.telemetry.MetricsUtils
Creates a metric name given the domain, group, and name.

G

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.
getApiSecretOrEmpty() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
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
 
getClientBuilder() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
getCollectors() - Method in class io.confluent.telemetry.reporter.TelemetryReporter
 
getCompressionAlgorithm(String) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
Get the compression algorithm.
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.MetricKey
 
getMetrics() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider
 
getMetrics() - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
 
getMetrics() - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector
 
getName() - Method in class io.confluent.telemetry.MetricKey
 
getNonResourceLabels(Map<String, String>) - Static method in class io.confluent.telemetry.provider.Utils
 
getProvider(String) - Static method in class io.confluent.telemetry.provider.ProviderRegistry
 
getProxyPassword() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
getProxyUrl() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
getProxyUsername() - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
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.MetricKey
 
histograms - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult
 
HOST_NAME_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
HOST_NAME_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
HttpExporter - Class in io.confluent.telemetry.exporter.http
 
HttpExporter(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
 

I

init(Properties) - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter
 
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.StateLedger
 
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.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.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.provider - package io.confluent.telemetry.provider
 
io.confluent.telemetry.reporter - package io.confluent.telemetry.reporter
 
io.confluent.telemetry.serde - package io.confluent.telemetry.serde
 
isDebugEnabled() - Method in class io.confluent.telemetry.Context
 
isEnabled() - Method in class io.confluent.telemetry.exporter.ExporterConfig
 

J

joinIncludeRegexList(List<String>) - Static method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
JvmMetricsCollector - Class in io.confluent.telemetry.collector
 
JvmMetricsCollector(Context, Predicate<MetricKey>) - Constructor for class io.confluent.telemetry.collector.JvmMetricsCollector
 
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.KafkaMetricsCollector
 
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(Predicate<MetricKey>, Context, KafkaMetricsCollector.StateLedger, Clock) - Constructor for class io.confluent.telemetry.collector.KafkaMetricsCollector
 
KafkaMetricsCollector.Builder - Class in io.confluent.telemetry.collector
 
KafkaMetricsCollector.StateLedger - Class in io.confluent.telemetry.collector
Keeps track of the state of metrics, e.g.
KafkaMetricsHelper - Class in io.confluent.metrics.reporter
 
KafkaRestProvider - Class in io.confluent.telemetry.provider
 
KafkaRestProvider() - Constructor for class io.confluent.telemetry.provider.KafkaRestProvider
 
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
 
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_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
 
meters - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult
 
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.StateLedger
 
metricChange(KafkaMetric) - Method in class io.confluent.telemetry.reporter.TelemetryReporter
This is called whenever a metric is updated or added
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 MetricsDetails
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.StateLedger
 
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_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
 
MetricsCollectorProvider - Interface in io.confluent.telemetry.collector
If an Exporter implements this interface, then we will also capture the metrics from this MetricsCollector and send them along.
MetricsCollectorTask - Class in io.confluent.telemetry
 
MetricsCollectorTask(Context, Supplier<Collection<Exporter>>, Collection<MetricsCollector>, long, Predicate<MetricKey>) - 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
 
metricWithSinglePointTimeseries(String, MetricDescriptor.Type, Map<String, String>, Point) - Method in class io.confluent.telemetry.Context
Build a Metric associated with this context's Resource having a single timeseries containing a single point.
metricWithSinglePointTimeseries(String, MetricDescriptor.Type, Map<String, String>, Point, Timestamp) - Method in class io.confluent.telemetry.Context
Build a Metric associated with this context's Resource having a single timeseries containing a single point.

N

name() - Method in class io.confluent.metrics.reporter.VolumeMetricsProvider.VolumeInfo
 
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.KafkaMetricsCollector
 
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.
newMetricBuilder() - Method in class io.confluent.telemetry.Context
Create a new MetricBuilderFacade pre-populated with this Context's Resource
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

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
 
PORT_DEFAULT - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
PORT_PROP - Static variable in class io.confluent.telemetry.BrokerConfigUtils
 
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_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(HttpExporterConfig) - Method in class io.confluent.telemetry.exporter.http.HttpExporter
 
reconfigure(KafkaExporterConfig) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter
 
reconfigure(Map<String, ?>) - Method in class io.confluent.telemetry.reporter.TelemetryReporter
 
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector
 
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector
 
reconfigurePredicate(Predicate<MetricKey>) - Method in interface io.confluent.telemetry.collector.MetricsCollector
Reconfigure the metrics predicate.
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector
 
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector
 
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.exporter.AbstractExporter
Reconfigure the metrics predicate.
reconfigurePredicate(Predicate<MetricKey>) - Method in interface io.confluent.telemetry.exporter.Exporter
Reconfigure the metrics predicate.
reconfigurePredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.MetricsCollectorTask
 
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
 
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
 

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
 
serialize(String, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
serialize(String, Headers, Metric) - Method in class io.confluent.telemetry.serde.OpencensusMetricsProto
 
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.KafkaMetricsCollector.Builder
 
setClock(Clock) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setContext(Context) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector.Builder
 
setContext(Context) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.Builder
 
setContext(Context) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder
 
setContext(Context) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setCreateTopic(boolean) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder
 
setDoubleDeltas(LastValueTracker<Double>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setLedger(KafkaMetricsCollector.StateLedger) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.Builder
 
setLogDirs(String[]) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder
 
setLongDeltas(LastValueTracker<Long>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setMetricsPredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.JvmMetricsCollector.Builder
 
setMetricsPredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.Builder
 
setMetricsPredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder
 
setMetricsPredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setMetricsPredicate(Predicate<MetricKey>) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder
 
setMetricsRegistry(MetricsRegistry) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setProducerProperties(Properties) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter.Builder
 
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
 
start() - Method in class io.confluent.telemetry.MetricsCollectorTask
 
StateLedger() - Constructor for class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
 
StateLedger(LastValueTracker<Double>, Clock) - Constructor for class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
 
STREAMS_APPLICATION_ID - Static variable in class io.confluent.telemetry.provider.KafkaStreamsProvider
 
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
 
TelemetryReporter - Class in io.confluent.telemetry.reporter
 
TelemetryReporter() - Constructor for class io.confluent.telemetry.reporter.TelemetryReporter
 
TelemetryReporter(EventLoggerFactory<ConfigEvent>) - Constructor for class io.confluent.telemetry.reporter.TelemetryReporter
 
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

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

withPrefixTranslation(String, String) - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder
Add a prefix translation.
withTranslation(String, String) - Method in class io.confluent.telemetry.ConfigPropertyTranslater.Builder
Add a property translation.
writeTo(ConsumerRecord<byte[], byte[]>, PrintStream) - Method in class io.confluent.metrics.reporter.ConfluentMetricsFormatter
 

Y

YAMMER_METRICS - Static variable in class io.confluent.telemetry.collector.YammerMetricsCollector
 
YammerMetricsCollector - Class in io.confluent.telemetry.collector
 
YammerMetricsCollector(MetricsRegistry, Predicate<MetricKey>, Context, 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