Hi Bo, How about write the data to Print Connector[1] simultaneously via insertInto[2]? It will print the data into Taskmanager's Log. Of course, you can choose an appropriate connector according to your audit log storage.
Best, Yu Chen [1] https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/table/print/ [2]https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/common/#emit-a-table ________________________________ 发件人: Bo <99...@qq.com> 发送时间: 2023年11月4日 13:53 收件人: user <user@flink.apache.org> 主题: Auditing sink using table api 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
