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

2021-05-18 文章 silence
可以在metrics 上报时或落地前对source两次上报间隔的numRecordsOut值进行相减,最后呈现的时候按时间段累计就可以了 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

2021-05-18 文章 zzzyw
是的,我们把这个信息集成到监控系统里面,其中有一项是统计随机时间的(例如最近1天,最近1周),kafka成功消费的数据量。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

2021-05-18 文章 yidan zhao
步长多少?随时随刻的最近24小时? zzzyw 于2021年5月18日周二 下午9:33写道: > Hi 各位, > 我需要统计出flink最近 n小时(例如24小时?) 成功从kafka中消费的数据量,有什么比较好的方案吗? > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/

如何统计n小时内,flink成功从kafka消费的数据量?

2021-05-18 文章 zzzyw
Hi 各位, 我需要统计出flink最近 n小时(例如24小时?) 成功从kafka中消费的数据量,有什么比较好的方案吗? -- Sent from: http://apache-flink.147419.n8.nabble.com/