conduktor.io ↗

KIP-138 — Change punctuate semantics

Accepted Kafka 1.0 Streams

KIP-138 refactors the Kafka Streams `Punctuator` API to support two independent scheduling modes: `STREAM_TIME` (driven by record timestamps) and `WALL_CLOCK_TIME` (driven by system wall-clock time), each schedulable independently per processor. Previously `punctuate()` was triggered only by stream-time advance, so wall-clock-based periodic actions (e.g., flushing caches) stalled whenever any input partition stopped receiving records.

Details

AuthorMichal Borowiecki
StatusAccepted
Kafka Version1.0
JIRAKAFKA-5233
WikiView on Apache Wiki
Created2017-04-03
Last Modified2017-09-08
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.