conduktor.io ↗

KIP-1146 — Anchored punctuation

Accepted Kafka 4.2 Streams

Adds anchored (wall-clock-aligned) punctuation to Kafka Streams so that periodic callbacks can be triggered at fixed calendar intervals (e.g., every hour at HH:00:00) regardless of when the punctuation was registered. Existing wall-clock punctuation starts its interval from registration time, producing non-deterministic trigger offsets relative to wall clock, which caused complex workarounds for time-aligned processing in sectors like energy grid balancing.

Details

AuthorHerman Kolstad Jakobsen
StatusAccepted
Kafka Version4.2
JIRAKAFKA-7699
WikiView on Apache Wiki
Created2025-03-15
Last Modified2025-07-01
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.