I started to read this KIP which contains a lot of materials.
One suggestion:
.suppress(
new Suppression()
Do you think it would be more consistent with the rest of Streams data
structures by supporting `of` ?
Suppression.of(Duration.ofMinutes(10))
Cheers
On Tue, Jun 26, 2018 at 1:11 PM, John Roesler <j...@confluent.io> wrote:
> Hello devs and users,
>
> Please take some time to consider this proposal for Kafka Streams:
>
> KIP-328: Ability to suppress updates for KTables
>
> link: https://cwiki.apache.org/confluence/x/sQU0BQ
>
> The basic idea is to provide:
> * more usable control over update rate (vs the current state store caches)
> * the final-result-for-windowed-computations feature which several people
> have requested
>
> I look forward to your feedback!
>
> Thanks,
> -John
>
