kafka/streams/streams-scala
Peter Lee c76fb5cb9b
KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join (#17756)
Currently, KTable foreign key joins only allow extracting the foreign key from the value of the source record. This forces users to duplicate data that might already exist in the key into the value when the foreign key needs to be derived from both the key and value. This leads to:

- Data duplication
- Additional storage overhead
- Potential data inconsistency if the duplicated data gets out of sync
- Less intuitive API when the foreign key is naturally derived from both key and value

This change allows user to extract the foreign key from the key and value of the source record.

Reviewers: Lucas Brutschy <lbrutschy@confluent.io>
2024-12-03 17:34:13 +01:00
..
src KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join (#17756) 2024-12-03 17:34:13 +01:00
.gitignore KAFKA-6670: Implement a Scala wrapper library for Kafka Streams 2018-04-23 13:33:35 -07:00