Feature proposal:

KTable<key, value> when(predicate);

I have a KTable, but I'd only like to trigger a stream processor on certain
conditions. I'd like to do something like:

myKtable.when(
     (key, value) -> some predicate
);

The result is just the same KTable. The predicate function is called on any
new event.

Thank you,
Nick DeCoursin

Reply via email to