Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-10886 Event time synchronization across sources
  3. FLINK-12675

Event time synchronization in Kafka consumer

    XMLWordPrintableJSON

Details

    Description

      Integrate the source watermark tracking into the Kafka consumer and implement the sync mechanism (different consumer model, compared to Kinesis).

      Attachments

        Issue Links

          is duplicated by

          New Feature - A new feature of the product, which has yet to be developed. FLINK-11186 Event-time balancing for multiple Kafka partitions

          • Major - Major loss of function.
          • Closed
          is related to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-28853 FLIP-217 Support watermark alignment of source splits

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link Design

          Web Link GitHub Pull Request #11968

          Activity

            People

              Unassigned Unassigned
              thw Thomas Weise
              Votes:
              3 Vote for this issue
              Watchers:
              18 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: