Hello All, This is KIP for the change of Class name from UsePreviousTimeOnInvalidTimeStamp to UsePartitionTimeOnInvalidTimeStamp. Link and Jira ticket is mentioned below:
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=130028807 https://issues.apache.org/jira/browse/KAFKA-8953 Would be pleased to get your feedback on this. With Best Regards, Rabi Kumar K C