可以在metrics 上报时或落地前对source两次上报间隔的numRecordsOut值进行相减,最后呈现的时候按时间段累计就可以了
--
Sent from: http://apache-flink.147419.n8.nabble.com/
是的,我们把这个信息集成到监控系统里面,其中有一项是统计随机时间的(例如最近1天,最近1周),kafka成功消费的数据量。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
步长多少?随时随刻的最近24小时?
zzzyw 于2021年5月18日周二 下午9:33写道:
> Hi 各位,
> 我需要统计出flink最近 n小时(例如24小时?) 成功从kafka中消费的数据量,有什么比较好的方案吗?
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
Hi 各位,
我需要统计出flink最近 n小时(例如24小时?) 成功从kafka中消费的数据量,有什么比较好的方案吗?
--
Sent from: http://apache-flink.147419.n8.nabble.com/