Package io.confluent.kafka.serializers.metrics

Class RuleMetrics

java.lang.Object

io.confluent.kafka.serializers.metrics.RuleMetrics

public final class RuleMetrics
extends Object

Rule-metrics registry for AbstractKafkaSchemaSerDe.

Owns the lazy registration of one Sensor (with a single CumulativeCount metric) per outcome / per rule tuple, and one gauge per rule tuple for the last-success timestamp. Metrics are registered against a PluginMetrics obtained via the Monitorable hook, so they ride the Kafka client's KIP-714 telemetry pipeline and are removed when the host plugin (the serializer/deserializer) closes.

Tag set per metric: rule_type, rule_mode (invocation mode), subject, rule_name, plus action on action metrics. config (key/value serializer) and class (simple class name) are added automatically by PluginMetricsImpl.

Constructor Summary

Constructors

Constructor	Description
RuleMetrics(org.apache.kafka.common.metrics.PluginMetrics pluginMetrics)

Method Summary

Modifier and Type	Method	Description
void	recordAction(Rule rule, RuleMode mode, String subject, String action)
void	recordExecution(Rule rule, RuleMode mode, String subject)
void	recordFailure(Rule rule, RuleMode mode, String subject)
void	recordSkipped(Rule rule, RuleMode mode, String subject)
void	recordSuccess(Rule rule, RuleMode mode, String subject)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RuleMetrics

public RuleMetrics(org.apache.kafka.common.metrics.PluginMetrics pluginMetrics)

Method Details

recordExecution

public void recordExecution(Rule rule,
 RuleMode mode,
 String subject)

recordSuccess

public void recordSuccess(Rule rule,
 RuleMode mode,
 String subject)

recordFailure

public void recordFailure(Rule rule,
 RuleMode mode,
 String subject)

recordSkipped

public void recordSkipped(Rule rule,
 RuleMode mode,
 String subject)

recordAction

public void recordAction(Rule rule,
 RuleMode mode,
 String subject,
 String action)