what are the maintainers' views on functions that don't directly wrap kafka/kstreams functionality living in the library? i've taken a look through the streams.clj file, it looks like it MAY be an intentionally light wrapper around kstreams. some background: for one of our kstreams apps we have a util function call divert? that'll push off a record if a given predicate is true (i.e. to a failure topic, etc):

(defn divert? [stream pred topic]
  (let [[divert-stream continue-stream] (j/branch stream [pred (constantly true])]
    (j/to divert-stream topic)
    continue-stream)

@ddouglass I don't think we are against abstractions that are not light wrappers around the java API, so that function could be useful, feel free to open a pr if you like

👌 i'll be working on it and get something up

PR is up 🙂