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