Hi, I have Use Case where i read events from a Single kafka Stream comprising of JSON messages.
Requirement is to split the stream into multiple output streams based on some criteria say based on Type of Event or Based on Type and Customer associated with the event. We could achieve the splitting of stream using Side outputs as i have seen in the documentation. Our business environment is such that there could be new event types flowing in and would the Flink Kafka producer create the topics dynamically based on the inflowing events. I did not see any documentation saying that it could create. Or should it be always pre created by running a script separately. (Not a good scalable practice in our case) Thanks, Prasanna.
