小编moh*_*pal的帖子

Flink流根据条件进入两个接收器

尝试根据条件查看流进入两个接收器的可能性。

要求是流有事件,转换后的所有事件都需要转到一个接收器(假设一个kafka主题)

并且只有错误事件需要转到另一个接收器(假设另一个kafka主题)。

没有看到一旦转换完成,附加逻辑放入接收器的用例。看看是否做过类似的事情

sink apache-flink flink-streaming

5
推荐指数
1
解决办法
1995
查看次数

标签 统计

apache-flink ×1

flink-streaming ×1

sink ×1