代码之家 › 专栏 › 技术社区 › xabhi

获取卡夫卡使用细节

kafka-producer-api kafka-consumer-api monitoring apache-kafka

xabhi · 技术社区 · 5 年前

我正在设法获取我的卡夫卡集群的当前使用统计数据。我希望收集以下信息:

任何其他可以而且应该收集的统计数据,目前我正在收集上述统计数据。

我可以使用zookeeper实用程序获得1和2,但我无法休息。我在Jconsole中查看了MBean,但没有发现任何关于上面的内容。我也尝试过使用基于JmxTool的表达式,但也没有成功。

我用的是卡夫卡v2。1和使用新的消费者api,这样zookeeper就不会有任何关于消费者的信息。

任何指点都会很有帮助!

1 回复 | 直到 5 年前

JR ibkr 5 年前

在$KAFKA_HOME/bin下有一些脚本可以帮助您。

卡夫卡集群中的主题数量

/卡夫卡主题。sh——动物园管理员本地主机:2181——列表

每个kafka代理的分区数

/卡夫卡主题。sh--动物园管理员本地主机:2181--描述一下

每个分区上的消息数、磁盘大小等。

/卡夫卡日志目录。sh--描述--引导服务器本地主机:9092

滞后复制品、消费者滞后等。

/卡夫卡消费群体。sh--引导服务器localhost:9092--组$group_NAME--描述

活跃的消费群体活跃消费者和生产者的数量

/卡夫卡消费群体。sh--引导服务器localhost:9092--列表

每个kafka broker的客户端连接数

推荐文章

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 年前