KIP-1293 — Add Time-Shift Parameter to Kafka Streams Punctuation Scheduling

Discarded Streams

Adds a time-shift parameter to Kafka Streams Punctuate scheduling so that the first punctuation fires at a fixed absolute time offset (e.g., next hour boundary) rather than relative to application start or the first processed record. Without this, punctuation timing is non-deterministic across restarts—a stream-time punctuation aligned to the first record's timestamp will drift after a restart if the first record has a different timestamp than on the previous run.

Details