Hello community,
I am looking for a way to perform auditing of the various sinks (mostly JdbcDynamicTableSink) using the table api. By "auditing", I mean to log details of every row data coming into the sink, and any anormalies when the sink write to external systems. Does flink have some kind of auditing mechanism in place? The only way I could see now is to make a custom sink that supports detail logging to external systems. Any thoughts/suggestions? Regards, Bo
