[KAFKA-8953] Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor

• Type: Improvement
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Fix Version/s: 2.5.0
• Component/s: streams
• Labels: beginner kip newbie
• Assignee: Rabi Kumar K C
• Reporter: Matthias J. Sax
• Created: 27/Sep/19 07:13
• Updated: 28/Jan/20 22:02
• Resolved: 09/Dec/19 03:23

Description

Kafka Streams ships couple of different timestamp extractors, one named `UsePreviousTimeOnInvalidTimestamp`.

Given the latest improvements with regard to time tracking, it seems appropriate to rename this class to `UsePartitionTimeOnInvalidTimestamp`, as we know have fixed definition of partition time, and also pass in partition time into the `#extract(...)` method, instead of some non-well-defined "previous timestamp".

KIP-530: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=130028807

Issue Links

• links to: GitHub Pull Request #7633
• mentioned in: Page Loading...