Kafka 代理指标集
编辑Kafka 代理指标集编辑
此功能处于测试阶段，可能会发生变化。设计和代码尚未成熟，与官方 GA 功能相比，成熟度较低，按“现状”提供，不提供任何保证。测试版功能不受官方 GA 功能支持 SLA 的约束。
此指标集定期从 Kafka 代理 JMX 提取 JMX 指标。
兼容性编辑
该模块已通过 Kafka 2.1.1 和 2.2.2 测试。预期其他版本也能正常工作。
使用编辑
代理指标集需要 Jolokia 来提取 JMX 指标。有关如何使用 Jolokia 的说明，请参阅链接。
请注意，Jolokia 代理需要与 Kafka JVM 应用程序一起部署。这可以通过在启动 Kafka 代理应用程序时使用 KAFKA_OPTS 环境变量来实现。
export KAFKA_OPTS=-javaagent:/opt/jolokia-jvm-1.5.0-agent.jar=port=8779,host=localhost ./bin/kafka-server-start.sh ./config/server.properties
然后，就可以从 localhost:8779 收集 JMX 指标。
有关指标集中每个字段的描述，请参阅 导出字段 部分。
以下是此指标集生成的示例文档
{
"@timestamp": "2019-10-30T14:22:37.475Z",
"@metadata": {
"beat": "metricbeat",
"type": "_doc",
"version": "8.0.0"
},
"agent": {
"ephemeral_id": "f08b3bea-3631-4aaf-b35d-4cef29aeeb06",
"hostname": "MBP.lan",
"id": "79dd1677-1bea-4efd-9131-e8ca464eddf0",
"version": "8.0.0",
"type": "metricbeat"
},
"ecs": {
"version": "1.2.0"
},
"metricset": {
"name": "broker",
"period": 10000
},
"service": {
"address": "localhost:8779",
"type": "kafka"
},
"kafka": {
"broker": {
"request": {
"fetch": {
"failed_per_second": 0
},
"channel": {
"queue": {
"size": 0
}
},
"produce": {
"failed_per_second": 0
}
},
"replication": {
"leader_elections": 0,
"unclean_leader_elections": 0
},
"session": {
"zookeeper": {
"expire": 0,
"readonly": 0,
"sync": 0.00017675970397749868,
"disconnect": 0
}
},
"topic": {
"net": {
"bytes_out": 0,
"bytes_rejected": 0,
"bytes_in": 0
},
"messages_in": 0
}
}
},
"event": {
"dataset": "kafka.broker",
"module": "kafka",
"duration": 7870293
},
"host": {
"name": "MBP.lan",
"hostname": "MBP.lan",
"architecture": "x86_64",
"os": {
"version": "10.14.6",
"family": "darwin",
"name": "Mac OS X",
"kernel": "18.7.0",
"build": "18G95",
"platform": "darwin"
},
"id": "883134FF-0EC4-5E1B-9F9E-FD06FB681D84"
}
}