需要一些flinksql流处理的例子。Kafka源码和数据库源码。
arknldoa1#
在ververica对flink sql的培训中，有很多很好的例子——https://github.com/ververica/sql-training. 这些例子使用了Kafka的一个源代码。目前正在开发对数据库来源的支持。Flink1.11将增加对jdbc（postgres）目录的支持。
1条答案
按热度按时间arknldoa1#
在ververica对flink sql的培训中，有很多很好的例子——https://github.com/ververica/sql-training. 这些例子使用了Kafka的一个源代码。
目前正在开发对数据库来源的支持。Flink1.11将增加对jdbc（postgres）目录的支持。