conduktor.io ↗

KIP-1365 — Transform Observability and Skipped Record Handling for Kafka Connect

Discussion ConnectMetrics

Adds per-transform operational metrics (record counts, throughput, error attribution) to the Kafka Connect SMT chain and a mechanism to inform sink connectors about records dropped or diverted before delivery. The `connector-transform-metrics` group exposes only static class name and version, so operators cannot tell how many records a filter drops or which transform in a chain is failing, and sink connectors see offset gaps for records they never received.

Details

AuthorPritam Kumar Mishra
StatusDiscussion
JIRAKAFKA-20797
WikiView on Apache Wiki
Created2026-07-10
Last Modified2026-07-11
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.