...
Current state: "Under discussion" [VOTE] KIP-77: Improve Kafka Streams Join Semantics
Discussion thread: HERE[DISCUSS] KIP-76: Improve Kafka Streams Join Semantics (this should have been KIP-77 – there was some confusion about KIP numbering)
JIRA: KAFKA-4001Released: 0.10.2.0KAFKA-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