我们需要使用存储在外部数据库中的附加信息来丰富数据流。
相关 Q. with arch diagram -如何组织一个复杂的 Apache Flink 应用程序？
此附加信息可能会发生变化，我们的应用程序必须对此做出响应。但这些变化很少见。
我发现要连接外部数据库，您需要使用 Table API。至少不支持将 DataStream JDBC 适配器作为数据源
组织此类应用程序的最佳方式是什么？以及哪个连接器，因为它们有很多。
如果使用 CDC 连接器？应用程序启动后如何延迟加载数据而不是从保存点？