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
| Author | Pritam Kumar Mishra |
| Status | Discussion |
| JIRA | KAFKA-20797 |
| Wiki | View on Apache Wiki |
| Created | 2026-07-10 |
| Last Modified | 2026-07-11 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.