大家好, 我现在有一个程序消费kafka,写入kafka,我想获取flink 消费了多少条kafka数据,写入了多少条kafka数据,,但是在flink页面上 第一个subtasks的Records received是0,最后一个subtask的Records send也是0,但是第一个subtask的Records send是正确的,最后一个subtask的Records received也是正确的。也就是我现在我不能从flink的metric中获取到flink程序从kafka中读了多少条数据,flink程序写入kafka多少条数据。 请问一下,我如何能从flink metric中得到从kafka消费了多少数据和写入kafka多少数据
非常感谢各位老师