0

我可以成功地将 mm 生产者/消费者指标集成到 check_mk。但是有一种类型的指标(consumer-node-metrics),它有一个参数(node-id)变量。它在应用程序的不同执行之间变化。我认为我们正在使用的 jmx.jar 对此负责。

我们使用 jolokia.cfg 进行配置。下面是我的配置文件。

    instances = [
   {
       "server"   : "127.0.0.1",
       "port"     : 8888,
       "instance" : "mm",
       "vars"     : [
            ( "kafka.consumer:client-id=mirrormaker-*,type=consumer-coordinator-metrics/commit-rate","gauge.commitRate",["","client-id"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,type=consumer-coordinator-metrics/commit-latency-avg","gauge.commitLatencyAvg",["","client-id"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,topic=*,type=consumer-fetch-manager-metrics/records-consumed-total","gauge.recordsConsumedTotal",["client-id","topic"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,topic=*,type=consumer-fetch-manager-metrics/bytes-consumed-total","gauge.bytesConsumedTotal",["client-id","topic"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,topic=*,partition=*,type=consumer-fetch-manager-metrics/records-lag","gauge.recordsLag",["client-id","topic"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,type=consumer-metrics/incoming-byte-rate","gauge.incomingByteRate",["","client-id"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,type=consumer-metrics/outgoing-byte-rate","gauge.outgoingByteRate",["","client-id"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,node-id=node-*,type=consumer-node-metrics/incoming-byte-rate","gauge.incomingByteRate",["client-id","node-id"] ),
            ( "kafka.consumer:client-id=mirrormaker-*,node-id=node-*,type=consumer-node-metrics/outgoing-byte-rate","gauge.outgoingByteRate",["client-id","node-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,type=producer-metrics/outgoing-byte-rate","gauge.outgoingByteRate",["","client-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,type=producer-metrics/incoming-byte-rate","gauge.incomingByteRate",["","client-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,type=producer-metrics/request-rate","gauge.requestRate",["","client-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,type=producer-metrics/response-rate","gauge.responseRate",["","client-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,node-id=node-*,type=producer-node-metrics/outgoing-byte-rate","gauge.outgoingByteRate",["client-id","node-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,node-id=node-*,type=producer-node-metrics/incoming-byte-rate","gauge.incomingByteRate",["client-id","node-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,node-id=node-*,type=producer-node-metrics/request-rate","gauge.requestRate",["client-id","node-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,node-id=node-*,type=producer-node-metrics/response-rate","gauge.responseRate",["client-id","node-id"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,topic=*,type=producer-topic-metrics/byte-rate","gauge.byteRate",["client-id","topic"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,topic=*,type=producer-topic-metrics/record-send-rate","gauge.recordSendRate",["client-id","topic"] ),
            ( "kafka.producer:client-id=mirror_maker_producer,topic=*,type=producer-topic-metrics/record-send-total","gauge.recordSendTotal",["client-id","topic"] )
       ]
   }
 ]

有没有办法让节点 id 保持不变?因为它一直在变化,然后 check_mk 无法识别它并说不受监控的服务。

请查看来自 check_mk 和 jconsole 的附加屏幕截图。

check_mk

mm上的Kafka消费者

4

0 回答 0