Nick, if I understand you correctly you can already do this today:
Think: KTable.toStream().filter().foreach() (or just KTable.filter().foreach(), depending on what you are aiming to do) Would that work for you? On Sun, Nov 13, 2016 at 12:12 AM, Nick DeCoursin <ndecour...@gmail.com> wrote: > 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 >
