基于FLIP-238的DataGeneratorSource能否生成Changelog DataStream？

当前版本的支持状态 #

FLIP-238引入的DataGeneratorSource目前不支持直接生成Changelog DataStream。它最初的设计定位是快速生成追加模式的测试数据流，默认只会产出INSERT类型的记录，没有内置能力生成UPDATE/DELETE这类变更日志条目。

未来的迭代规划 #

社区在FLINK-27919的议题中已经提出了为DataGeneratorSource添加变更日志生成能力的需求，目的是方便用户测试需要处理变更日志的Flink作业（比如维表关联、状态更新这类场景）。不过该功能目前还在规划或开发阶段，具体上线时间暂未确定，建议关注Flink社区的更新动态。

内容的提问来源于stack exchange，提问作者discord