Table of Contents |
---|
Status
Current state: "Under Discussion"Accepted
Discussion thread: here
JIRA: KAFKA-8953
...
Code Block | ||
---|---|---|
| ||
public long onInvalidTimestamp(final ConsumerRecord<Object, Object> record, final long recordTimestamp, final long partitionTime) throws StreamsException { ... } |
Proposed Changes
Change 'UsePartitionTimeOnInvalidTimeStampUsePreviousTimeOnInvalidTimeStamp' to 'UsePartitionTimeOnInvalidTimestamp'
...
UsePreviousTimeOnInvalidTimestamp won't be present instead 'UsePartitionOnInvalidTimeStamp' will be there in next major version without change in the functionality but it's clear from the name that this will be used for partition time . But we will deprecate UsePreviousTimeOnInvalidTimeStamp first and then introduce new onebut UsePreviousTimeOnInvalidTimeStamp will need to be deprecated first.
Rejected Alternatives
None.