do I have to send the errors "in band"? that is, return maybe more than one tuple in my operations then flatmap and use a KeyedSerializationSchema?
or is there a way to emit a tuple to another sink from within operations directly? On Wed, Oct 26, 2016 at 9:20 AM, Robert Metzger <rmetz...@apache.org> wrote: > Hi Luis, > > You can define as many data sinks as you want in a Flink job topology. > So its not a problem for your use case to define two Kafka sinks, sending > data to different topics. > > Regards, > Robert > > > On Tue, Oct 25, 2016 at 3:30 PM, Luis Mariano Guerra < > mari...@event-fabric.com> wrote: > >> hi, >> >> I'm migrating some samza jobs to flink streaming, and on samza we sent >> the errors to a kafka topic to make it easier to display on dashboards, I >> would like to do the same on flink, what do you recommend? >> >> >> >
