Hello all, I am proposing KIP-274 to improve the metrics around skipped records in Streams.
Please find the details here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-274%3A+Kafka+Streams+Skipped+Records+Metrics Please let me know what you think! Thanks, -John