[ https://issues.apache.org/jira/browse/KAFKA-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942777#comment-16942777 ]
Rabi Kumar K C commented on KAFKA-8953: --------------------------------------- Hi [~mjsax] Wrote emails to [d...@kafka.apache.org|mailto:d...@kafka.apache.org] but didn't get any response regarding permission. Would you able to help in this scenario? Confluence id: rabikumar.kc > 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 > Assignee: Rabi Kumar K C > Priority: Trivial > Labels: beginner, needs-kip, newbie > > 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)