Re: 如何统计n小时内，flink成功从kafka消费的数据量？

[silence]

可以在metrics 上报时或落地前对source两次上报间隔的numRecordsOut值进行相减，最后呈现的时候按时间段累计就可以了



--
Sent from: http://apache-flink.147419.n8.nabble.com/