You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2021/06/07 22:15:00 UTC
[jira] [Updated] (KAFKA-8613) Make grace period mandatory
[ https://issues.apache.org/jira/browse/KAFKA-8613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax updated KAFKA-8613:
-----------------------------------
Description:
Currently, the grace period is set to retention time if the grace period is not specified explicitly. The reason for setting the default grace period to retention time was backward compatibility. Topologies that were implemented before the introduction of the grace period, added late arriving records to a window as long as the window existed, i.e., as long as its retention time was not elapsed.
This unintuitive default grace period has already caused confusion among users.
For the next major release, we should consider to set the default grace period to {{Duration.ZERO}}. or to make it a mandatory parameter.
KIP-633 [https://cwiki.apache.org/confluence/display/KAFKA/KIP-633%3A+Drop+24+hour+default+of+grace+period+in+Streams]
was:
Currently, the grace period is set to retention time if the grace period is not specified explicitly. The reason for setting the default grace period to retention time was backward compatibility. Topologies that were implemented before the introduction of the grace period, added late arriving records to a window as long as the window existed, i.e., as long as its retention time was not elapsed.
This unintuitive default grace period has already caused confusion among users.
For the next major release, we should set the default grace period to {{Duration.ZERO}}.
KIP-633 [https://cwiki.apache.org/confluence/display/KAFKA/KIP-633%3A+Drop+24+hour+default+of+grace+period+in+Streams]
> Make grace period mandatory
> ---------------------------
>
> Key: KAFKA-8613
> URL: https://issues.apache.org/jira/browse/KAFKA-8613
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Bruno Cadonna
> Assignee: Israel Ekpo
> Priority: Blocker
> Labels: kip
> Fix For: 3.0.0
>
>
> Currently, the grace period is set to retention time if the grace period is not specified explicitly. The reason for setting the default grace period to retention time was backward compatibility. Topologies that were implemented before the introduction of the grace period, added late arriving records to a window as long as the window existed, i.e., as long as its retention time was not elapsed.
> This unintuitive default grace period has already caused confusion among users.
> For the next major release, we should consider to set the default grace period to {{Duration.ZERO}}. or to make it a mandatory parameter.
>
> KIP-633 [https://cwiki.apache.org/confluence/display/KAFKA/KIP-633%3A+Drop+24+hour+default+of+grace+period+in+Streams]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)