KIP-251 — Allow timestamp manipulation in Processor API

Accepted Kafka 2.0 Streams

Adds a ProcessorContext#setTimestamp() method to the Streams Processor API, allowing processors to override the timestamp that will be used for output records and punctuation scheduling. Without this, the timestamp of output records is always inherited from the input record, making it impossible to implement custom timestamp semantics like event-time enrichment or timestamp correction in the low-level API.

Details