search

FundingCircle / jackdaw

A Clojure library for the Apache Kafka distributed streaming platform.
https://fundingcircle.github.io/jackdaw/
BSD 3-Clause "New" or "Revised" License
369 stars 80 forks source link

support foreign key joins #364

Closed raymcdermott closed 10 months ago

raymcdermott commented 10 months ago

Add support for the join arity 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-

minimal commented 10 months ago

closed by #365