Class SensorValidationMetricsRecorder

java.lang.Object

io.confluent.kafka.schemaregistry.validator.core.SensorValidationMetricsRecorder

All Implemented Interfaces:

ValidationMetricsRecorder

public final class SensorValidationMetricsRecorder
extends Object
implements ValidationMetricsRecorder

Records validation metrics into Kafka Sensors.

Each sensor is held in an AtomicReference because it is wired up after construction — the broker supplies metrics via RecordInterceptor.setMetrics, and in Confluent Cloud the sensors are re-pointed whenever the Schema Registry endpoint config changes. A sensor that has not been set yet is silently skipped.

Field Summary

Fields

Modifier and Type	Field	Description
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	clientErrorsSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	connectionErrorsSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	headerRecordSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	headerRejectedSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	headerRetrySensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	noneRecordSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	noneRejectedSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	noneRetrySensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	payloadRecordSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	payloadRejectedSensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	payloadRetrySensor
final AtomicReference<org.apache.kafka.common.metrics.Sensor>	serverErrorsSensor

Fields inherited from interface ValidationMetricsRecorder

NOOP

Constructor Summary

Constructors

Constructor	Description
SensorValidationMetricsRecorder()

Method Summary

Modifier and Type	Method	Description
void	recordClientError()	A 4xx from Schema Registry.
void	recordConnectionError()	A failure reaching Schema Registry at all (connection level).
void	recordRecord(SchemaIdType schemaIdType)	A validated record, tagged by where its schema id was found.
void	recordRejected(SchemaIdType schemaIdType)	A record rejected by validation.
void	recordRetry(SchemaIdType schemaIdType)	A record whose validation could not complete from cache and will be retried.
void	recordServerError()	A 5xx from Schema Registry.

Methods inherited from class Object

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

Field Details

connectionErrorsSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> connectionErrorsSensor

clientErrorsSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> clientErrorsSensor

serverErrorsSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> serverErrorsSensor

headerRecordSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> headerRecordSensor

payloadRecordSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> payloadRecordSensor

noneRecordSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> noneRecordSensor

headerRejectedSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> headerRejectedSensor

payloadRejectedSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> payloadRejectedSensor

noneRejectedSensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> noneRejectedSensor

headerRetrySensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> headerRetrySensor

payloadRetrySensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> payloadRetrySensor

noneRetrySensor

public final AtomicReference<org.apache.kafka.common.metrics.Sensor> noneRetrySensor

Constructor Details

SensorValidationMetricsRecorder

public SensorValidationMetricsRecorder()

Method Details

recordRecord

public void recordRecord(SchemaIdType schemaIdType)

Description copied from interface: ValidationMetricsRecorder

A validated record, tagged by where its schema id was found.

Specified by:

recordRecord in interface ValidationMetricsRecorder

recordRejected

public void recordRejected(SchemaIdType schemaIdType)

Description copied from interface: ValidationMetricsRecorder

A record rejected by validation.

Specified by:

recordRejected in interface ValidationMetricsRecorder

recordRetry

public void recordRetry(SchemaIdType schemaIdType)

Description copied from interface: ValidationMetricsRecorder

A record whose validation could not complete from cache and will be retried.

Specified by:

recordRetry in interface ValidationMetricsRecorder

recordConnectionError

public void recordConnectionError()

Description copied from interface: ValidationMetricsRecorder

A failure reaching Schema Registry at all (connection level).

Specified by:

recordConnectionError in interface ValidationMetricsRecorder

recordClientError

public void recordClientError()

Description copied from interface: ValidationMetricsRecorder

A 4xx from Schema Registry.

Specified by:

recordClientError in interface ValidationMetricsRecorder

recordServerError

public void recordServerError()

Description copied from interface: ValidationMetricsRecorder

A 5xx from Schema Registry.

Specified by:

recordServerError in interface ValidationMetricsRecorder