Hi, I have started using flink recently in my application. i am trying to save a transformed data stream to an oracle db. I was currently using writeascsv(filepath), to save the data to a file. When i say data, it is the kafka message. This kafka message is a file name. I used kafka consumer to read the message and the flink jobmanager will read the file, groups the file data for the flink taskmanagers for parallel processing. Using keyed stream, the file data is grouped. Used writeascsv api to save this grouped data which creates files for each group.
Instead of saving the grouped data to file, i want to save it to an oracledb table. Also, is it possible to use spring jdbctemplate to achieve this? Could you please provide some help? Regards, Mn
