FundingCircle / jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.

https://fundingcircle.github.io/jackdaw/

BSD 3-Clause "New" or "Revised" License

368 stars 80 forks source link

Add foreign key join. Issue #364 #365

Closed raymcdermott closed 7 months ago

raymcdermott commented 7 months ago

Add support for the join arity of a ktable that accepts a foreign-key-extractor function

Blog post that introduces the feature

https://www.confluent.io/blog/data-enrichment-with-kafka-streams-foreign-key-joins/

Official API

https://kafka.apache.org/24/javadoc/org/apache/kafka/streams/kstream/KTable.html#join-org.apache.kafka.streams.kstream.KTable-java.util.function.Function-org.apache.kafka.streams.kstream.ValueJoiner-

Checklist

[X] tests
[X] updated CHANGELOG (the "unreleased" section)

fc-infosec-sast commented 7 months ago

✅ SAST Report

No issues found. Good job! 💪

minimal commented 7 months ago

LTGM aside from the minor comments