Clojurians Log v2

hello 👋

I’m trying to use jackdaw to implement a window-by-time, count, suppress, and output program almost identical to this java https://docs.confluent.io/platform/current/streams/developer-guide/dsl-api.html#window-final-results :

KGroupedStream<UserId, Event> grouped = ...;
grouped
    .windowedBy(TimeWindows.of(Duration.ofHours(1)).grace(Duration.ofMinutes(10)))
    .count()
    .suppress(Suppressed.untilWindowCloses(unbounded()))
    .filter((windowedUserId, count) -> count < 3)
    .toStream()
    .foreach((windowedUserId, count) -> sendAlert(windowedUserId.window(), windowedUserId.key(), count));

My code using jackdaw function wrappers around the same kstreams methods:

(defn build-topology!
         [config builder]
         (-> (js/kstream builder (config/topic (:INPUT_TOPIC config)))
          (js/filter moder/moderated?)
          (js/group-by (fn [[_ v]] (:goalId v)))
          (js/window-by-time (.grace (TimeWindows/of (Duration/ofMinutes 5)) (Duration/ofMillis 1)))
          (js/count)
          (js/suppress {})
          (js/to-kstream)
          (js/print!) ...

java.lang.RuntimeException: No reader function for tag object
	at clojure.lang.EdnReader$TaggedReader.readTagged(EdnReader.java:801) ...

Has anyone come across this before? It has me totally stumped, as I’m not sure what suppress is trying to serde or why it is going wrong