Hi Victor, Firstly, you can get your side output stream via OutputTag. Please refer to the official documentation[1]. Then, specify a sink for your side output stream. Of course, you can specify a Kafka sink.
Best, Vino [1]: https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html Victor Villa Dev <victor.villa....@gmail.com> 于2019年11月25日周一 上午2:27写道： > I'd like know if there's a way to generate a side output and/or sink to an > alternate kafka topic from within a Sink? > The use case is the datastream sinks to a storage and on particular failed > attempts I'd like to deadletter to a kafka topic. > Any suggestions? > > Thanks >
