Versions Compared

Old Version 15

changes.mady.by.user Herman Kolstad Jakobsen

Saved on

compared with

New Version 16

changes.mady.by.user Herman Kolstad Jakobsen

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

The goal is to introduce an anchored wall-clock punctuation that will have functionally similarities with that of running a cron job. The proposed API change is to extend the `schedule()` method in the `ProcessingContext` interface with a parameter to represent the start time in epoch milliseconds for the schedule's anchored time, without enforcing any changes upon the existing users:

Code Block
titleProposed API change
package org.apache.kafka.streams.processor.api;

public interface ProcessingContext {

	// New method allowing for anchored punctuation
	Cancellable schedule(final Duration interval, final long startTime, final PunctuationType type, final Punctuator callback);

	// Existing method
 	Cancellable schedule(final Duration interval, final long startTime, final PunctuationType type, final Punctuator callback) {
		schedule(interval, null, type, callback);
	}
}

...