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

Reply via email to