代码之家 › 专栏 › 技术社区 › Vijay Kumar

每单位时间在Kafka主题中接收的新邮件数

apache-kafka

0

Vijay Kumar · 技术社区 · 6 年前

我试图在给定的卡夫卡主题中绘制每单位时间(分钟或小时)接收的新消息数。

我看到过一些关于在一个主题中查找当前消息数量的帖子。作为一个潜在的解决方案,我可以在每个时间间隔查询这个数字,但是,这不考虑过期邮件(由于保留时间)。

有没有办法得到每单位时间在卡夫卡主题中接收到的新消息的数量?

0 回复 | 直到 6 年前

1

Amin 6 年前

在jmx度量中,您可以找到 kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec 表示传入消息的速率。您可以将其存储在普罗米修斯或其他时间序列数据库中,并根据时间进行查询。