[jira] [Resolved] (KAFKA-8504) Update Docs to explain how to use suppress() in more details

["Matthias J. Sax (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Matthias J. Sax resolved KAFKA-8504.
------------------------------------
    Fix Version/s: 4.0.0
       Resolution: Fixed

No fix needed after API changes delivered in AK 3.0.0 (and AK 4.0.0).

Cf discussions on the PR.

> Update Docs to explain how to use suppress() in more details
> ------------------------------------------------------------
>
>                 Key: KAFKA-8504
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8504
>             Project: Kafka
>          Issue Type: Improvement
>          Components: documentation, streams
>    Affects Versions: 2.2.1
>            Reporter: Simone Esposito
>            Assignee: Emmanuel Oppong
>            Priority: Minor
>              Labels: newbie
>             Fix For: 4.0.0
>
>
> Hi, I'm playing a bit with KafkaStream and the new suppress feature. I noticed that when using a {{TimeWindows}} without explicitly setting the grace {{suppress}} will not emit any message if used with {{Suppressed.untilWindowCloses.}}
> I look a bit into the code and from what I understood with this configuration {{suppress}} should use the {{grace}} setting of the {{TimeWindows}}. But since using {{TimeWindows.of(Duration)}} default the grace to {{-1}} and when getting the grace using the method {{TimeWindows.gracePeriodMs()}} in case of grace equals to -1 the return value is set to {{maintainMs() - size()}} I think that the end of window is not properly calculated. 
> Of course is possible to avoid this problem forcing the {{grace}} to 0 when creating the TimeWindows but I think that this should be the default behaviour at least when it comes to the suppress feature.
> I hope I have not misunderstood the code in my analysis, thank you :)
> Simone



--
This message was sent by Atlassian Jira
(v8.20.10#820010)