Status
Current state: "Under discussion"
Discussion thread: HERE
JIRA: KAFKA-4144
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
Motivation
At the moment the timestamp extractor is configured via a StreamConfig
value to KafkaStreams
. That means you can only have a single timestamp extractor per app, even though you may be joining multiple streams/tables
that require different timestamp extraction methods.
Ideally the user should be able to specify a timestamp extractor via KStreamBuilder.stream/table
, just like you can specify key and value serdes that override the StreamConfig
defaults.
Public Interfaces