flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From C DINESH <dinesh.kitt...@gmail.com>
Subject Dynamic source and sink.
Date Sun, 28 Jun 2020 07:30:28 GMT
Hi All,

In a flink job I have a pipeline. It is consuming data from one kafka topic
and storing data to Elastic search cluster.

without restarting the job can we add another kafka cluster and another
elastic search sink to the job. Which means i will supply the new kafka
cluster and elastic search details in the topic.  After consuming the data
can our flink job add the new source and sink to the same job.

Thanks & Regards,

View raw message