Hi Lei, Yes. Currently, Kafka sink only supports append mode. Other update mode (e.g. upsert mode / retract mode) is on the agenda. For now, you can customize a KafkaTableSink with implementing UpsertStreamTableSink interface, where you will get a Tuple2<Boolean, Row> records, and the Boolean represents insert or delete operation. Then you can encode the insert/delete operation into Kafka storage or just ignore the operations.
Best, Jark On Mon, 9 Mar 2020 at 19:14, wangl...@geekplus.com.cn < wangl...@geekplus.com.cn> wrote: > I wrote a simple program reading from kafka using sql and sink to kafka. > But only 'update-mode' = 'append' is supported for sink table and the > query sql must have no group statement. > Only append mode is supported for kafka sink? > > Thanks, > Lei > > >
