源算子是没有接收统计的，只有发送统计，sink算子刚好相反。
发件人： [email protected] 发送时间： 2019-05-10 17:28 收件人： [email protected] 主题： flink 无法 获取从数据源读了多少条数据，写入目标数据源多少条数据 大家好， 我现在有一个程序消费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多少数据 非常感谢各位老师
