Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Proposed Changes

This KIP proposes a new DSL entry point points that passes pass the join key (the result of the KeyValueMapper) to ValueJoinerWithKey, restoring the spirit of , and deprecates the original overloads that pass the stream record's key, so that readOnlyKey aligns with the join key as described in KIP-149 for stream-globalTable joins.

When a record arrives on the stream:

...

Would require introducing a new ValueJoinerWithKeys interface accepting both keys. Rejected for this KIP, whose scope is limited to honoring KIP-149's existing readOnlyKey contract. It can be revisited as a separate KIP if demand emerges