你好，DataStream 的方式需要设置 includeSchemaChanges(true) 参数，并且设置自定义的 deserializer，参考这个链接[1]。 如果不想使用 json 的方式，希望自定义 deserializer，从 SourceRecord 里提取 ddl 的方式可以参考这个链接[2]提供的方案。
[1] https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/faq/faq/#q6-i-want-to-get-ddl-events-in-the-database-what-should-i-do-is-there-a-demo [2] https://developer.aliyun.com/article/1093413#slide-2 zapjone <zapj...@163.com> 于2024年6月13日周四 12:29写道： > 大佬们好： > 想请假下，在flink > cdc3.0中支持schema变更，但看到是pipeline方式的，因业务问题需要使用datastream进行特殊处理，所以想请假下，在flink > cdc 3.0中datastream api中怎么使用schema变更呢？或者相关文档呢？
