Re: Re: Kafka sink only support append mode?

2020-03-10 Thread Jark Wu
Wu > *Date:* 2020-03-09 19:25 > *To:* wangl...@geekplus.com.cn > *CC:* user > *Subject:* Re: Kafka sink only support append mode? > 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

Re: Re: Kafka sink only support append mode?

2020-03-10 Thread wangl...@geekplus.com.cn
is not appendable. It confused me. Thanks, Lei From: Jark Wu Date: 2020-03-09 19:25 To: wangl...@geekplus.com.cn CC: user Subject: Re: Kafka sink only support append mode? Hi Lei, Yes. Currently, Kafka sink only supports append mode. Other update mode (e.g. upsert mode / retract mode) is on the agenda

Re: Kafka sink only support append mode?

2020-03-09 Thread Jark Wu
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 records, and the Boolean represents insert