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)
