尝试根据条件查看流进入两个接收器的可能性。
要求是流有事件,转换后的所有事件都需要转到一个接收器(假设一个kafka主题)
并且只有错误事件需要转到另一个接收器(假设另一个kafka主题)。
没有看到一旦转换完成,附加逻辑放入接收器的用例。看看是否做过类似的事情
sink apache-flink flink-streaming
apache-flink ×1
flink-streaming ×1
sink ×1