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
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.
For
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