Hello guys, i would like to know if there is any possibility to emit an event when a sink has finished. To put it in context, I have a simple ETL (streaming bounded) that reads data from a database, maps, and inserts into another database. Once I finish inserting the data I want to issue an event to kafka to notify another process.
I can think of some solutions, but I am not convinced which one is the best option: - dividing the stream into two paths and with a session window, in onTimer, check if the last record is already in the database - Implement custom sink - ... Any suggestions? Thanks! -- Antonio Manzano Tejón Tel: 699 333 556
