Matthias J. Sax created KAFKA-8953: -------------------------------------- Summary: Consider renaming `UsePreviousTimeOnInvalidTimestamp` timestamp extractor Key: KAFKA-8953 URL: https://issues.apache.org/jira/browse/KAFKA-8953 Project: Kafka Issue Type: Improvement Components: streams Reporter: Matthias J. Sax
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". -- This message was sent by Atlassian Jira (v8.3.4#803005)