各位大佬，咨询个技术方面的思路问题，不知道下面的思路是否合适：1、背景： 昨天看美团搭建#Flink

各位大佬，咨询个技术方面的思路问题，不知道下面的思路是否合适： 1、背景： 昨天看美团搭建实时数库的架构设计PPT(https://developer.aliyun.com/article/741468?spm=a2c6h.15056366.J_4429179800.8.13d43d64IrWQR6) 中，各种汇总层(像dws层,ads层) 都写在kafka中; 2、问题点：目前的KafkaTableSink只支持append模式写kafka,暂不支持upset模式,无法实现写实时流的汇总数据到kafka（比如通过KafkaTableSink是无法实现以下sql写kafka的：INSERT INTO user_log_sink SELECT item_id, category_id, behavior, max(ts), min(proctime), max(proctime), count(user_id) FROM user_log group by item_id, category_id, behavior;） ； 3、解决方案1：自已实现一个upset模式的KafkaUpsertTableSink, 实现将flink汇总的数据写入kafka（注：继承自UpsertStreamTableSink，参考https://www.cnblogs.com/Springmoon-venn/p/12652845.html ） 以上是我的思路，但尚未实现过，群里有大佬在真实环境中实现过的吗？或者上面思路本身就有问题(将汇总数据写kafka)?#Flink