Skip to content

Waiting until window closes #12

@danieroux

Description

@danieroux

I have this function, I am not sure where in kafka.clj it should fit:

(defn wait-until-window-closes [^KTable builder]
  (.suppress builder (Suppressed/untilWindowCloses (Suppressed$BufferConfig/unbounded))))

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions