KIP-274 — Kafka Streams Skipped Records Metrics

Accepted Kafka 2.0 StreamsMetrics

Adds per-operator skipped-records-rate and skipped-records-total metrics to Kafka Streams, broken down by thread, task, and processor node. The existing skipped-records metrics were only aggregated at the thread level, making it impossible to identify which specific operator or topology node was encountering and skipping malformed or null-key records.

Details