接收器可以成为 Apache Flink 中的下一个数据源吗

Question

我正在使用 Apache Flink 处理流数据。

说我有两个 jar 文件 a.jar 和 b.jar。我的问题是是否可以使用 a.jar 的接收器作为 b.jar 的数据源。

如果可以的话，你能给我举个简单的例子吗？

如果没有，我该怎么办？我必须使用数据库之类的东西来存储 a.jar 的接收器的输出并将数据库用作 b.jar 的数据源吗？

Answer 1

要获得恰好一次保证，您必须使用支持事务和流重放的流存储层来实现这种解耦。