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

Migrate BufferedUpsertSinkFunction to FLIP-143

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 1.14.0
    • None

    Description

      The BufferedUpsertSinkFunction is still using the old sink interfaces and relies on the old Kafka DataStream connector FlinkKafkaProducer.

      We need to migrate it to the new Sink API to also leverage the new KafkaSink connector and finally deprecate the FlinkKafkaProducer and all its belongings.

      Attachments

        Issue Links

          causes

          Bug - A problem which impairs or prevents the functions of the product. FLINK-24596 Bugs in sink.buffer-flush before upsert-kafka

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

          Web Link GitHub Pull Request #16796

          Activity

            People

              fpaul Fabian Paul
              fpaul Fabian Paul
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: