KIP-123 — Allow per stream/table timestamp extractor

Accepted Kafka 1.0 Streams

Allows a per-stream/per-table `TimestampExtractor` to be specified in `KStreamBuilder.stream()` and `KStreamBuilder.table()` overloads, overriding the global `StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG`. A single global timestamp extractor cannot handle topologies that join streams with different timestamp semantics (e.g., event-time vs. log-append-time from different source systems).

Details