【发布时间】：2021-11-16 11:29:19
【问题描述】：
有什么方法可以在 Flink 中自动推断 Kafka 主题 DDL 而无需手动查询 CREATE TABLE，就像在 spark 的情况下一样。
【问题讨论】：
标签： apache-flink flink-streaming flink-sql
【发布时间】：2021-11-16 11:29:19
【问题描述】：
您可以使用 Flink 目录连接到元数据存储库，请参阅 https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/catalogs/
【讨论】：
-
但是也使用目录，我们正在注册它，有没有什么方法可以让我只将kafka主题和格式作为输入并flink自动推断它，并且可以在下游SQL中使用同样的方法
-
您是否有示例说明如何在 Spark 中执行此操作？最后，您必须注册一些元数据才能将组件链接在一起。
-
我的错，谢谢推荐目录