Hi All, I am new to Flink, request your help!!! My scenario : 1> we receive Json messages at a very high frequency like 10,000 messages / second2> we need to raise an Alert for a particular user if there is any breach in threshold value against each attribute in Json.3> These threshold values are part of my database table and can be frequently updated by different user.4> In realtime I would like to know how to get latest data from the database. I tried using Flink CEP Pattern approach to generate alert. I would like to get some inputs on how I can implement the realtime lookup tables in Flink Java while monitoring alert, any sample code reference. Also for such scenarios do you recommend to use Flink CEP approach or we need to use Process function approach.
Regards,Sunitha.
