snskshn

When I consume KTable, it is materialized as KeyValueStore automatically. ```kotlin fun process() = BiConsumer { input, table -> input.join(table) { value1, value2 -> Pair(value1, value2) }.peek { key, value...

What's the usage of require_before/require_after?

1

As I understood, things like as follows: // case1. without require_before A B.after_all(A) // A -> B C.after_all(B) // A -> B -> C // case2. with require_before A B.require_after(A).after_all(A)...