New

The executive guide to generative AI

Read more
About usPartnersSupport|Login
« Kafka 模块 Kafka consumer 指标集 »
Elastic 文档 ›Metricbeat 参考 [8.17] ›模块 ›Kafka 模块

Kafka broker 指标集

编辑

Kafka broker 指标集

编辑

此功能为 Beta 版，可能会发生更改。 其设计和代码不如官方 GA 功能成熟，按“原样”提供，不提供任何保证。 Beta 功能不受官方 GA 功能的支持 SLA 约束。

此指标集定期从 Kafka Broker JMX 获取 JMX 指标。

兼容性

编辑

该模块已使用 Kafka 2.1.1 和 2.2.2 进行测试。预计其他版本也能正常工作。

用法

编辑

Broker 指标集需要 Jolokia 来获取 JMX 指标。有关如何使用 Jolokia 的说明，请参阅该链接。

请注意，需要将 Jolokia 代理与 Kafka JVM 应用程序一起部署。这可以通过在启动 Kafka broker 应用程序时使用 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"
    }
}
« Kafka 模块 Kafka consumer 指标集 »
Was this helpful?
Feedback