[
https://issues.apache.org/jira/browse/KAFKA-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16859804#comment-16859804
]
Simone commented on KAFKA-8504:
-------------------------------
Yeah, I understand that due to backward compatibility is not easy to fix this
but I agree with you about the docs and I think that given the workaround is
quite simple (just need to set a custom grace period) probably a good written
documentation could be enough (for now at least)
Thank you very much for the reply :)
> Suppressed do not emit with TimeWindows
> ---------------------------------------
>
> 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
> Priority: Minor
>
> 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
(v7.6.3#76005)
