From 9dc64083e236c84aef047695f38265471cfd5e3d Mon Sep 17 00:00:00 2001 From: Jeremy Van de Wyngaert Date: Fri, 22 Dec 2023 10:21:44 +0100 Subject: [PATCH] configured: add missing configured/join with topic configs --- src/jackdaw/streams/configured.clj | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/jackdaw/streams/configured.clj b/src/jackdaw/streams/configured.clj index 8f045137..8c78ca2e 100644 --- a/src/jackdaw/streams/configured.clj +++ b/src/jackdaw/streams/configured.clj @@ -81,6 +81,12 @@ config (join kstream ktable value-joiner-fn))) + (join + [_ ktable value-joiner-fn topic-config other-topic-config] + (configured-kstream + config + (join kstream ktable value-joiner-fn topic-config other-topic-config))) + (left-join [_ ktable value-joiner-fn] (configured-kstream