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

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

apache-kafka

Vijay Kumar · 技术社区 · 5 年前

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

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

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

0 回复 | 直到 5 年前

Amin 5 年前

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

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

2 年前

Sravan Kumar · Apache kafka模式注册表问题

2 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

2 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

2 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

2 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

2 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前