There was a long discussion about this. You can read the thread[1]. Best, Jark
[1]: https://lists.apache.org/thread/sr6on0cq52ns4y3zh6j0x899by80n5zw On Wed, 24 Aug 2022 at 13:20, Yufei Zhang <a...@apache.org> wrote: > Hi all, > > I noticed there is a Upsert-Kafka SQL Connector[1] and the Kafka SQL > Connector[2], my question is why do we implement them as two different > connectors? For example, why not add a `upsert` config option in the Kafka > SQL connector to specify whether the table enables upsert mode or not. Is > there a special consideration that we have to use a different connector > name like `upsert-kafka` and implement a different > DynamicSource/SinkFactory ? > > Thank you in advance~ > > Cheers, > Yufei > > > > > > > > - [1] : > > https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/upsert-kafka/ > > - [2]: > > https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/kafka >
