Hi flink users, I used Async IO (RichAsyncFunction) for sending 100 txns to a 3rd party.
I check the runtimeContex that it has metric of numRecordsSent, we wanted to expose this metric to our prometheus server so that we can monitor how much records we are sending per second. The reason why we need to monitor, is because there is additional cost for every additional txn exceeding the allowed tps for us to send. Any input would be appreciated. Regards, Patricia
