有个需求,就是用flink消费kafka的数据。经过一些列的逻辑处理后存入mysql,怎么验证或者说监控存入mysql的数据的正确性呢?有什么方法吗
同样的的逻辑,这个跑批任务对一下数
`单行代码`
关注海汼部落技术社区