KIP-472 — [STREAMS] Add partition time field to RecordContext
Discarded Kafka 2.4 Streams
Proposes adding a `partitionTime()` accessor to `RecordContext` in Kafka Streams so processors can read the current partition time (stream-time high-watermark for that partition) alongside the individual record timestamp (discarded as too complex for the marginal benefit). When a filter processor drops the highest-timestamp records, downstream tasks inherit an incorrect (too-high) partition time that causes premature window and grace period advancement.
Details
| Author | Richard Yu |
| Status | Discarded |
| Kafka Version | 2.4 |
| JIRA | KAFKA-7994 |
| Wiki | View on Apache Wiki |
| Created | 2019-05-19 |
| Last Modified | 2019-06-01 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.