...

public long onInvalidTimestamp(final ConsumerRecord<Object, Object> record, final long recordTimestamp, final long partitionTime)

throws StreamsException {

. . .

}

Proposed Changes

Change 'UsePartitionTimeOnInvalidTimeStamp'  to 'UsePartitionTimeOnInvalidTimestamp'

...

If we check the implementation of onInvalidTimestamp present in 'UsePreviousTimeOnInvalidTimestamp' which is abstract method of super class  ExtractRecordMetadataTimestamp argument long previousTimestamp has been changed to long partitionTime so it seems reasonable for us to change the class name as main functionality of this class is to return the valid time stamp of record's partition.

...