Hi,

In my problem I should Process Kafka messages Using Apache Flink, while
some processing parameters should be read from the CouchDB, So I have two
questions:

1- What is Flink way to read data from the CouchDB?
2- I want to trigger Flink to load data from the Couch DB if a new document
was inserted into the table, instead of reading data from the database in
every message processing. What should be my strategy in such an
environment? I think I need some trigger or event handler? Does Flink
provide any facilities for this?

Thanks

Reply via email to