KIP-93 — Improve invalid timestamp handling in Kafka Streams

Accepted Streams

KIP-93 changes the `TimestampExtractor` interface to receive the previously extracted timestamp as a hint and return a non-negative timestamp instead of propagating negative values, and adds a configurable `default.timestamp.extractor` that uses the hint to carry forward the last valid timestamp. Negative timestamps (returned for pre-0.10 message-format records or by custom extractors) caused Kafka Streams to crash with an unhandled exception because time-based operators like windowed aggregates and joins cannot handle them.

Details