Details

    • Hide
      Table API/SQL write to Kafka with the new `KafkaSink`. When migrating from a query writing to Kafka in exactly-once mode from an earlier Flink version, make sure to terminate the old application with stop-with-savepoint to avoid lingering Kafka transactions. To run in exactly-once processing mode, the sink needs a user-configured and unique transaction prefix, such that transactions of different applications do not interfere with each other.
      Show
      Table API/SQL write to Kafka with the new `KafkaSink`. When migrating from a query writing to Kafka in exactly-once mode from an earlier Flink version, make sure to terminate the old application with stop-with-savepoint to avoid lingering Kafka transactions. To run in exactly-once processing mode, the sink needs a user-configured and unique transaction prefix, such that transactions of different applications do not interfere with each other.

    Description

      With the KafkaSink ported to FLIP-143 we should also adapt the Table API to leverage the new KafkaSink

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: