文件名称:ConsumerLatency:检索JSON形式的Kafka消费者滞后的简单工具
文件大小:32.81MB
文件格式:ZIP
更新时间:2024-05-29 17:58:14
kafka kafka-consumer kafka-producer kafka-connector Java
消费群体滞后 kafka-consumer-groups.sh --describe的替代方法- kafka-consumer-groups.sh --describe : 是比较快的 可在Kafka版本上使用(针对经纪人0.10.0.0、0.10.1.1、0.10.2.0、0.11.0.1进行了测试) 也可以将信息输出为JSON(用于管道输入脚本) 在消耗180个分区的使用者组上的时间安排: kafka-consumer-groups.sh 22 seconds ConsumerGroupLag 1 second Timing on a consumer group that consumes 800 partitions from a remote Kafka cluster: kafka-consumer-groups.sh 230 second
【文件预览】:
ConsumerLatency-master
----gradlew(5KB)
----src()
--------main()
----build()
--------tmp()
--------classes()
--------scripts()
--------distributions()
--------libs()
--------resources()
----gradle()
--------wrapper()
----README.md(4KB)
----.gradle()
--------3.1()
----gradlew.bat(2KB)
----build.gradle(999B)