flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "jszhouchong@163.com" <jszhouch...@163.com>
Subject flink 无法 获取从数据源读了多少条数据,写入目标数据源多少条数据
Date Fri, 10 May 2019 09:28:21 GMT
大家好,
我现在有一个程序消费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多少数据


非常感谢各位老师
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message