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

left/outer joins can wait indefinitely for emitted record with spurious record fix

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • streams
    • None

    Description

      With the fix in https://issues.apache.org/jira/browse/KAFKA-10847 records will be emitted after the grace period but only when a new record is processed. This means its possible to wait for arbitrary long time for a record to be emitted.

      This also means one can not recreate the previous semantics of emitting immediately records or even now guaranteed emitting after the grace period.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue KAFKA-17531 Remove deprecates methods JoinWindows#of and #grace

          • Blocker - Blocks development and/or testing work, production could not run
          • Open
          is caused by

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-10847 Avoid spurious left/outer join results in stream-stream join

          • Major - Major loss of function.
          • Resolved

          Activity

            People

              Unassigned Unassigned
              camcliveseldon Clive Cox
              Votes:
              1 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated: