Zapjone 好，
目前的 Schema Evolution 的实现依赖传递 CDC Event 事件的 Pipeline 连接器和框架。如果您希望插入自定义算子逻辑，建议参考
flink-cdc-composer 模块中的 FlinkPipelineComposer 类构建算子链作业的方式，并在其中插入自定义的 Operator
以实现您的业务逻辑。
另外，对于一些简单的处理逻辑，如果能够使用 YAML 作业的 Route（路由）、Transform（变换）功能表述的话，直接编写对应的 YAML
规则会更简单。
祝好！
Regards,
yux
De : zapjone <zapj...@163.com>
Date : jeudi, 13 juin 2024 à 12:29
À : user-zh@flink.apache.org <user-zh@flink.apache.org>
Objet : flink cdc 3.0 schema变更问题
大佬们好：
想请假下，在flink
cdc3.0中支持schema变更，但看到是pipeline方式的，因业务问题需要使用datastream进行特殊处理，所以想请假下，在flink cdc
3.0中datastream api中怎么使用schema变更呢？或者相关文档呢？
