需要 flink-sql 流处理的一些示例

Question

需要一些 flink-sql 流处理的示例。 kafka 源和数据库源。

Answer 1

Ververica对Flink的训练有很多很好的例子SQL -- https://github.com/ververica/sql-training。这些示例使用 Kafka 源。

目前正在开发对数据库源的支持。 Flink 1.11 将添加对 JDBC (Postgres) 目录的支持。