THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
UsePreviousTimeOnInvalidTimeStamp will be deprecated if class name is changed.
Code Block | ||
---|---|---|
| ||
public class UsePartitionTimeOnInvalidTimestamp extends ExtractRecordMetadataTimestamp {
...
} |
Proposed Changes
Previously, in Kafka 2.3 we had the following methods inside 'UsePreviousTimeOnInvalidTimestamp'
...