@Override
    public String toString() {
        return "CorruptedRecord(" +
            "value = " + value +
            ")";
    }
This class represents a version of a {@link StampedRecord} that failed to deserialize. We need
a special record type so that {@link StreamTask} can update consumed offsets. See KAFKA-6502
for more details.
streams/src/main/java/org/apache/kafka/streams/processor/internals/CorruptedRecord.java