Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8613

Make Grace Period Mandatory for Windowed Operations in Streams

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 3.1.0, 3.0.0
    • streams

    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/x/Ho2NCg

       

      Attachments

        Issue Links

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            iekpo Israel Ekpo
            cadonna Bruno Cadonna
            Votes:
            0 Vote for this issue
            Watchers:
            9 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment