flink中的API源支持

Question

flink是否提供了一种定期从API进行轮询的方式，并从中创建一个数据流对象以进一步处理？

我们目前将消息推向Kafka并通过Kafka阅读。有什么方法可以直接通过Flink进行对API进行投票？

Answer 1

我不知道Flink的源连接器，但是实现一个源连接器是相对简单的。有一些示例只是这样做的，但是有数据库查询。其中之一可能是入门的模板。