flink是否提供了一种定期从api轮询并从中创建数据流对象以供进一步处理的方法？我们现在把这些信息推给Kafka并通读Kafka。有没有办法直接通过flink轮询api？
fslejnso1#
我不知道flink有这样的源代码连接器，但是实现一个相对简单。有这样的例子，但与数据库查询；其中之一可以作为入门的模板。
1条答案
按热度按时间fslejnso1#
我不知道flink有这样的源代码连接器，但是实现一个相对简单。有这样的例子，但与数据库查询；其中之一可以作为入门的模板。