Dear Kafka community,

I am proposing KIP-274 to improve visibility when Streams skips invalid records.

The proposal is to simplify the metrics and add warning logs.

Please find details in the wiki:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-274%3A+Kafka+Streams+Skipped+Records+Metrics

Thanks,

-John

Reply via email to