Re: Routing events to different kafka topics dynamically

Great to hear :-) Cheers, Till On Thu, Dec 3, 2020 at 10:15 AM Prasanna kumar < prasannakumarram...@gmail.com> wrote: > Thanks Till, > > Able to deduce topics by extending the KafkaSerializarion Schema class. > > Prasanna. > > On Wed, Dec 2, 2020 at 11:18 PM Till Rohrmann > wrote: > >> Hi Prasa

Re: Routing events to different kafka topics dynamically

Thanks Till, Able to deduce topics by extending the KafkaSerializarion Schema class. Prasanna. On Wed, Dec 2, 2020 at 11:18 PM Till Rohrmann wrote: > Hi Prasanna, > > I believe that what Aljoscha suggestd in the linked discussion is still > the best way to go forward. Given your description of

Re: Routing events to different kafka topics dynamically

Hi Prasanna, I believe that what Aljoscha suggestd in the linked discussion is still the best way to go forward. Given your description of the problem this should actually be pretty straightforward as you can deduce the topic from the message. Hence, you just need to create the ProducerRecord with

Routing events to different kafka topics dynamically

Hi, Events need to be routed to different kafka topics dynamically based upon some info in the message. We have implemented using KeyedSerializationSchema similar to https://stackoverflow.com/questions/49508508/apache-flink-how-to-sink-events-to-different-kafka-topics-depending-on-the-even. But i