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