Skip navigation links
A B C D E F G H I K L M N O P R S T U V W Y 

A

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_KEY - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
API_SECRET_KEY_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
 
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.CPUMetricsCollector.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
 

C

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.KafkaServerMetricsReporter
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.CPUMetricsCollector
 
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_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(ConfluentTelemetryConfig, Context, String) - Method in interface io.confluent.telemetry.collector.MetricsCollectorProvider
 
collector(ConfluentTelemetryConfig, Context, String) - Method in class io.confluent.telemetry.exporter.http.HttpExporter
 
collector(ConfluentTelemetryConfig, Context, String) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter
 
collectYammerMetrics(MetricsRegistry, Pattern) - Method in class io.confluent.metrics.reporter.YammerMetricsHelper
 
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.reporter.KafkaServerMetricsReporter
Configure this class with the given key-value pairs
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
 
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(Properties) - Constructor for class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
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
 
Context - Class in io.confluent.telemetry
Context for metrics collectors.
Context() - Constructor for class io.confluent.telemetry.Context
 
Context(Resource) - Constructor for class io.confluent.telemetry.Context
 
Context(Resource, boolean) - Constructor for class io.confluent.telemetry.Context
 
Context(Resource, boolean, boolean) - Constructor for class io.confluent.telemetry.Context
 
convertCase(String) - Static method in class io.confluent.telemetry.MetricsUtils
Converts a tag/name to match the telemetry naming conventions by converting snake_case.
CPUMetricsCollector - Class in io.confluent.telemetry.collector
 
CPUMetricsCollector(Context, String, Predicate<MetricKey>) - Constructor for class io.confluent.telemetry.collector.CPUMetricsCollector
 
CPUMetricsCollector.Builder - Class in io.confluent.telemetry.collector
 
createHttpExporterConfig() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
Create a HttpExporterConfig from these properties if enabled
createKafkaExporterConfig() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
Create a KafkaExporterConfig from these properties if enabled

D

DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEBUG_ENABLED_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_BROKER_MONITORING_METRICS - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
DEFAULT_BROKER_MONITORING_METRICS - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_COLLECT_INTERVAL - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
DEFAULT_DEBUG_ENABLED - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
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_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
 
DEFAULT_WHITELIST - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
DEFAULT_WHITELIST - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
delta(MetricName, Instant, Double) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.StateLedger
 
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
 

E

emit(Metric) - Method in interface io.confluent.telemetry.exporter.Exporter
 
emit(Metric) - Method in class io.confluent.telemetry.exporter.http.HttpExporter
 
emit(Metric) - Method in class io.confluent.telemetry.exporter.kafka.KafkaExporter
 
EMPTY_STRING - Static variable in class io.confluent.metrics.reporter.Utils
 
equals(Object) - Method in class io.confluent.telemetry.MetricKey
 
Exporter - Interface in io.confluent.telemetry.exporter
 
EXPORTER_HTTP_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
EXPORTER_HTTP_ENABLED_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
EXPORTER_HTTP_ENABLED_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
EXPORTER_KAFKA_ENABLED_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
EXPORTER_KAFKA_ENABLED_DEFAULT - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
EXPORTER_KAFKA_ENABLED_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 

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.
getBrokerId() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
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.KafkaServerMetricsReporter
 
getCompressionAlgorithm(String) - Method in class io.confluent.telemetry.exporter.http.HttpExporterConfig
Get the compression algorithm.
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
 
getMetricWhitelistFilter() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
Get a predicate that filters metrics based on the whitelist configuration.
getName() - Method in class io.confluent.telemetry.MetricKey
 
getResource() - Method in class io.confluent.telemetry.Context
Get the Resource in this Context.
getValue() - Method in class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue
 
getVolumeMetricsCollectorConfig() - Method in class io.confluent.telemetry.ConfluentTelemetryConfig
 
GROUP - Static variable in class io.confluent.telemetry.exporter.http.HttpExporter
 

H

hashCode() - Method in class io.confluent.telemetry.MetricKey
 
histograms - Variable in class io.confluent.metrics.reporter.YammerMetricsHelper.YammerMetricsResult
 
HttpExporter - Class in io.confluent.telemetry.exporter.http
 
HttpExporter(HttpExporterConfig) - Constructor for class io.confluent.telemetry.exporter.http.HttpExporter
 
HttpExporter(BufferingAsyncTelemetryHttpClient<Metric, ExportMetricsServiceRequest, ExportMetricsServiceResponse>) - 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
 

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.KafkaServerMetricsReporter
This is called when the collectorTask is first registered to initially register all existing metrics
InstantAndValue(Instant, T) - Constructor for class io.confluent.telemetry.collector.LastValueTracker.InstantAndValue
 
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.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.reporter - package io.confluent.telemetry.reporter
 
io.confluent.telemetry.serde - package io.confluent.telemetry.serde
 
isDebugEnabled() - Method in class io.confluent.telemetry.Context
 

K

KAFKA - Static variable in class io.confluent.telemetry.reporter.KafkaServerMetricsReporter
 
KAFKA_METRICS_LIB - Static variable in class io.confluent.telemetry.collector.KafkaMetricsCollector
 
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
 
KafkaMetricsCollector - Class in io.confluent.telemetry.collector
 
KafkaMetricsCollector(Predicate<MetricKey>, Context, String, 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
 
KafkaServerMetricsReporter - Class in io.confluent.telemetry.reporter
 
KafkaServerMetricsReporter() - Constructor for class io.confluent.telemetry.reporter.KafkaServerMetricsReporter
 

L

LABEL_BROKER_ID - Static variable in class io.confluent.telemetry.reporter.KafkaServerMetricsReporter
 
LABEL_CLUSTER_ID - Static variable in class io.confluent.telemetry.reporter.KafkaServerMetricsReporter
 
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
 
LEGACY_PREFIX - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
LIBRARY_NONE - Static variable in interface io.confluent.telemetry.collector.MetricsCollector

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.KafkaServerMetricsReporter
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.KafkaServerMetricsReporter
This is called whenever a metric is removed
metricReportRunnable() - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter
 
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, Set<Exporter>, Collection<MetricsCollector>, long) - Constructor for class io.confluent.telemetry.MetricsCollectorTask
 
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

newBuilder(ConfluentTelemetryConfig) - Static method in class io.confluent.telemetry.collector.CPUMetricsCollector
Create a new Builder using values from the ConfluentTelemetryConfig.
newBuilder() - Static method in class io.confluent.telemetry.collector.CPUMetricsCollector
 
newBuilder(ConfluentTelemetryConfig) - Static method in class io.confluent.telemetry.collector.KafkaMetricsCollector
Create a new Builder using values from the ConfluentTelemetryConfig.
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(ConfluentTelemetryConfig) - Static method in class io.confluent.telemetry.collector.YammerMetricsCollector
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
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
 

O

onUpdate(ClusterResource) - Method in class io.confluent.metrics.reporter.ConfluentMetricsReporter
 
onUpdate(ClusterResource) - Method in class io.confluent.telemetry.reporter.KafkaServerMetricsReporter
 
OpencensusMetricsProto - Class in io.confluent.telemetry.serde
 
OpencensusMetricsProto() - Constructor for class io.confluent.telemetry.serde.OpencensusMetricsProto
 

P

PREFIX - Static variable in class io.confluent.telemetry.collector.VolumeMetricsCollector.VolumeMetricsCollectorConfig
 
PREFIX - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
PREFIX - Static variable in class io.confluent.telemetry.exporter.http.HttpExporterConfig
 
PREFIX - Static variable in class io.confluent.telemetry.exporter.kafka.KafkaExporterConfig
 
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
 
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
 
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

remove(MetricKey) - Method in class io.confluent.telemetry.collector.LastValueTracker
 

S

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.CPUMetricsCollector.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
 
setDomain(String) - Method in class io.confluent.telemetry.collector.CPUMetricsCollector.Builder
 
setDomain(String) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.Builder
 
setDomain(String) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder
 
setDomain(String) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.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
 
setMetricsRegistry(MetricsRegistry) - Method in class io.confluent.telemetry.collector.YammerMetricsCollector.Builder
 
setMetricWhitelistFilter(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.CPUMetricsCollector.Builder
 
setMetricWhitelistFilter(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.KafkaMetricsCollector.Builder
 
setMetricWhitelistFilter(Predicate<MetricKey>) - Method in class io.confluent.telemetry.collector.VolumeMetricsCollector.Builder
 
setMetricWhitelistFilter(Predicate<MetricKey>) - 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
 

T

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.telemetry.collector.CPUMetricsCollector
 
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
 
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.

U

Utils - Class in io.confluent.metrics.reporter
 

V

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
 
VolumeMetricsProvider - Class in io.confluent.metrics.reporter
 
VolumeMetricsProvider(long, String[]) - Constructor for class io.confluent.metrics.reporter.VolumeMetricsProvider
Create a volume metrics provider.

W

WHITELIST_CONFIG - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
WHITELIST_CONFIG - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
WHITELIST_DOC - Static variable in class io.confluent.metrics.reporter.ConfluentMetricsReporterConfig
 
WHITELIST_DOC - Static variable in class io.confluent.telemetry.ConfluentTelemetryConfig
 
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(String, 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 K L M N O P R S T U V W Y 
Skip navigation links