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
| Author | Michal Borowiecki |
| Status | Accepted |
| Kafka Version | 1.0 |
| JIRA | KAFKA-5233 |
| Wiki | View on Apache Wiki |
| Created | 2017-04-03 |
| Last Modified | 2017-09-08 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.