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

Question

试图根据条件看到流到两个水槽的可能性。

Requirement is stream have events, all events after transformation need to go to one sink ( assume one kafka topic)

And only error events needs to go to another sink ( assume another kafka topic).

一旦完成转换的用例，都没有将其他逻辑放入水槽中。看是否做类似的事情

Answer 1

最好的方法是使用。

private static final OutputTag<String> errors = new OutputTag<>("errors") {};

...

// in your main() method
SingleOutputStreamOperator<T> result = events.process(new ProcessFunction());

result.addSink(sink).name("normal output");
result.getSideOutput(errors).addSink(errorSink).name("error output");

...

// in the process function

if (somethingGoesWrong) {
    ctx.output(errors, "error message");
}

虽然还有其他方法可以将流动的流链分开，但侧输出非常灵活（例如，侧输出可以具有不同的类型）并且表现良好。