[ https://issues.apache.org/jira/browse/KAFKA-8953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939179#comment-16939179 ]
Rabi Kumar K C commented on KAFKA-8953: --------------------------------------- Hi [~mjsax] I am new to Kafka. Is it okay if I take this up? As I am new I cannot assign the ticket to myself. > 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 > 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)