Hi Kafka Community, I would like to start a discussion on KIP-1365, which proposes adding instrumentation around Kafka Connect transforms and introducing a new API for the sink connectors to handle the skipped records (whether filtered or dlq'ed).
More motivation for this and more implementation related details can be found in the following KIP. KIP link: https://cwiki.apache.org/confluence/spaces/KAFKA/pages/440304156/KIP-1365+Transform+Observability+and+Skipped+Record+Handling+for+Kafka+Connect Looking forward to your comments! Regards, Pritam Kumar On Sat, Jul 11, 2026 at 8:08 PM pritam kumar <[email protected]> wrote: > Hello Kafka Community, > > I would like to start a discussion on KIP-1365, which proposes adding > instrumentation around Kafka Connect transforms and introducing a new API > for the sink connectors to handle the skipped records (whether filtered or > dlq'ed). > > KIP link: > https://cwiki.apache.org/confluence/spaces/KAFKA/pages/440304156/KIP-1365+Transform+Observability+and+Skipped+Record+Handling+for+Kafka+Connect > > Thanks, > Pritam Kumar >
