Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-22902 Port KafkaSink to new Unified Sink API (FLIP-143)
  3. FLINK-23814

Test FLIP-143 KafkaSink

    XMLWordPrintableJSON

Details

    Description

      The following scenarios are worthwhile to test

      • Start simple job with None/At-least once delivery guarantee and write records to kafka topic
      • Start simple job with exactly-once delivery guarantee and write records to kafka topic. The records should only be visible with a `read-committed` consumer
      • Stop a job with exactly-once delivery guarantee and restart it with different parallelism (scale-down, scale-up)
      • Restart/kill a taskmanager while writing in exactly-once mode

      Attachments

        Issue Links

          relates to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-23896 The new KafkaSink drops data if job fails between checkpoint and transaction commit.

          • Blocker - Blocks development and/or testing work, production could not run
          • Resolved

          Activity

            People

              ruanhang1993 Hang Ruan
              fpaul Fabian Paul
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: