Sounds like your describing a source function that subscribes to couch
db updates. You'd usually implement this as a Co(Flat)MapFunction that
has 2 inputs, 1 from kafka and one from couch db, which stores the
processing parameters in state.
There's no built-in way to subscribe to couch db upda
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 inse
