hermanjakobsen opened a new pull request, #19937: URL: https://github.com/apache/kafka/pull/19937
This PR implements Processor API interfaces for using Anchored punctuation. As described in https://cwiki.apache.org/confluence/display/KAFKA/KIP-1146%3A+Anchored+punctuation, anchored punctuations allows the users of the PAPI to set both a start time and an interval for when the punctuations should be triggered. The changes consist of introducing new interfaces as the punctuation time logic in the `org.apache.kafka.streams.processor.internals.PunctuationSchedule` already supports calculating a new punctuation time based on a start time and an interval. The original `schedule()` implementations have been refactored into using the new `schedule()` implementation supporting the `startTime` parameter. For the original implementations, the `startTime` parameter has been sat to `null`, effectively using the "method overloading" programming technique. The following unit tests have been implemented - checking that no exception is thrown when registering an anchored schedule for a stream task - checking that the desired punctuation start time is sat using the `MockProcessorContext` has been implemented. The changes do not break any of the original schedule unit tests. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
