I believe you only need to declare the system stream you are writing to
before hand . ie your Kafka broker list if you are using Kafka. If auto
create topics is enabled, you can dynamically write to any topic within a
predefined system stream. I'd suggest simply use a hash map of topic to
OutputStr
Hi,
Is there a way to assign dynamically in the job code the topic where the output
messages should be sent to? I am testing an idea that needs to decide
programmatically (and not in from limited range) the destination topic. As I am
understanding it, I need to declare the output format in the
