Hi:
we use flink as a router to our kafka, we read from one kafka and to a lot
of diffrent kafka and topic,
but it will cost too much time to start the flink job if we want to add some
other kafka sink to the flink, so
if there any way to dynamic add sink to flink or just start the flink job
faster? The reason of slow start flink
job I think is the lots of kafka sink.
We now use the demo code like this,
<code>
splitStream = stream.split(by the content)
for ((k, v) <- map) {
splitStream.select(k).addSink(new kafkaSink(v))
}
</code>
