Hi Alessandro, If you want to get each update to an aggregate, you need to disable the cache. Otherwise, an update will only be emitted when the aggregate is evicted or flushed from the cache.
To disable the cache, you can: - disable it with the `Materialized` object - set cache.max.bytes.buffering to zero which disables all caches in the topology Best, Bruno On Mon, Sep 16, 2019 at 12:11 PM Alessandro Tagliapietra <tagliapietra.alessan...@gmail.com> wrote: > > Hello everyone, > > I've this code > https://gist.github.com/alex88/719383f38541c5324caf8f47b7239e15 (I've > omitted the store setup part) and i've this problem for a specific key. > Basically I can see the logs up until the "Pair Stream data". "Aggregate > stream data" line is never logger. > > Since between these lines there's just the groupByKey and WindowedBy, are > there any logics in these two that could stop the flow of data? Since I > don't have any window closing mechanism or suppression shouldn't it just go > through? > > Thank you in advance > > -- > Alessandro Tagliapietra
