Hi！ 不太明白这个需求，但如果希望发送给不同的 topic，需要给每个 topic 都定义 DDL。
如果是因为各 topic 之间的 schema 重复度比较高，只有些许字段以及 topic 名称等不同，可以看一下 DDL LIKE 语法： https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/table/sql/create/#like casel.chen <[email protected]> 于2021年9月18日周六 上午8:27写道： > 上游kafka topic消息带有一个用户类型字段，现在想根据不同用户类型将数据发到不同topic（为了扩展不想写死有哪些类型) ，请问flink > sql支持动态创建sink table吗？
