Fabian Paul created FLINK-23735:
-----------------------------------

             Summary: Migrate BufferedUpsertSinkFunction to FLIP-143
                 Key: FLINK-23735
                 URL: https://issues.apache.org/jira/browse/FLINK-23735
             Project: Flink
          Issue Type: Sub-task
            Reporter: Fabian Paul


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to